lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] HoodieFileScanRDD could print null path (#5056)

Browse Source 
Co-authored-by: Rex An <bonean131@gmail.com>
This commit is contained in:
RexAn
2022-03-18 03:53:45 +08:00
committed by GitHub
parent 7446ff95a7
commit 9ece77561a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieFileScanRDD.scala
View File

@@ -47,8 +47,8 @@ class HoodieFileScanRDD(@transient private val sparkSession: SparkSession,
/** Advances to the next file. Returns true if a new non-empty iterator is available. */ /** Advances to the next file. Returns true if a new non-empty iterator is available. */
private def nextIterator(): Boolean = { private def nextIterator(): Boolean = {
if (files.hasNext) { if (files.hasNext) {
logInfo(s"Reading File $currentFile")
currentFile = files.next() currentFile = files.next()
logInfo(s"Reading File $currentFile")
currentIterator = readFunction(currentFile) currentIterator = readFunction(currentFile)
try { try {