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 <[email protected]>
AuthorDate: Fri Mar 18 03:53:45 2022 +0800
[MINOR] HoodieFileScanRDD could print null path (#5056)
Co-authored-by: Rex An <[email protected]>
---
.../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 {
