This is an automated email from the ASF dual-hosted git repository. yihua pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push: new 9ece775 [MINOR] HoodieFileScanRDD could print null path (#5056) 9ece775 is described below commit 9ece77561a673fbfd666c5c57dac1a36e6cedce6 Author: RexAn <anh...@126.com> AuthorDate: Fri Mar 18 03:53:45 2022 +0800 [MINOR] HoodieFileScanRDD could print null path (#5056) Co-authored-by: Rex An <bonean...@gmail.com> --- .../src/main/scala/org/apache/hudi/HoodieFileScanRDD.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieFileScanRDD.scala b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieFileScanRDD.scala index 7e8f62b..aef6fc0 100644 --- a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieFileScanRDD.scala +++ b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieFileScanRDD.scala @@ -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. */ private def nextIterator(): Boolean = { if (files.hasNext) { - logInfo(s"Reading File $currentFile") currentFile = files.next() + logInfo(s"Reading File $currentFile") currentIterator = readFunction(currentFile) try {