[hudi] branch master updated: [MINOR] Fix caller to SparkBulkInsertCommitActionExecutor (#2195)

[vi...@apache.org]

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 <27...@users.noreply.github.com>
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,