This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new c64c00ffd [Bug][Connector]Hudi Source loads the data twice
c64c00ffd is described below
commit c64c00ffd6978737a34c66d3ab7ce2da76683766
Author: superzhang0929 <[email protected]>
AuthorDate: Tue Jul 19 13:15:21 2022 +0800
[Bug][Connector]Hudi Source loads the data twice
---
.../src/main/scala/org/apache/seatunnel/spark/hudi/source/Hudi.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/hudi/source/Hudi.scala
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/hudi/source/Hudi.scala
index 82e55f09a..a1d42862c 100644
---
a/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/hudi/source/Hudi.scala
+++
b/seatunnel-connectors/seatunnel-connectors-spark/seatunnel-connector-spark-hudi/src/main/scala/org/apache/seatunnel/spark/hudi/source/Hudi.scala
@@ -38,7 +38,7 @@ class Hudi extends SparkBatchSource {
reader.option(e.getKey, String.valueOf(e.getValue.unwrapped()))
}
- reader.load(config.getString(HOODIE_DATASTORE_READ_PATHS))
+ reader.load()
}
override def getPluginName: String = "Hudi"
