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 {

Reply via email to