This is an automated email from the ASF dual-hosted git repository.
vinoth 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 14c4611 [MINOR] Fix caller to SparkBulkInsertCommitActionExecutor
(#2195)
14c4611 is described below
commit 14c4611857ea796b8d3aef96f867db9cd0ae31f7
Author: Raymond Xu <[email protected]>
AuthorDate: Wed Oct 21 19:50:10 2020 -0700
[MINOR] Fix caller to SparkBulkInsertCommitActionExecutor (#2195)
Fixed calling the wrong constructor
---
.../hudi/table/action/bootstrap/SparkBootstrapCommitActionExecutor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/SparkBootstrapCommitActionExecutor.java
b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/SparkBootstrapCommitActionExecutor.java
index 64df78c..2dd9fd0 100644
---
a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/SparkBootstrapCommitActionExecutor.java
+++
b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/SparkBootstrapCommitActionExecutor.java
@@ -284,7 +284,7 @@ public class SparkBootstrapCommitActionExecutor<T extends
HoodieRecordPayload<T>
protected BaseSparkCommitActionExecutor<T>
getBulkInsertActionExecutor(JavaRDD<HoodieRecord> inputRecordsRDD) {
return new SparkBulkInsertCommitActionExecutor((HoodieSparkEngineContext)
context, new HoodieWriteConfig.Builder().withProps(config.getProps())
.withSchema(bootstrapSchema).build(), table,
HoodieTimeline.FULL_BOOTSTRAP_INSTANT_TS,
- inputRecordsRDD, extraMetadata);
+ inputRecordsRDD, Option.empty(), extraMetadata);
}
private BootstrapWriteStatus handleMetadataBootstrap(String
srcPartitionPath, String partitionPath,
