lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fix caller to SparkBulkInsertCommitActionExecutor (#2195)

Browse Source 
Fixed calling the wrong constructor
This commit is contained in:
Raymond Xu
2020-10-21 19:50:10 -07:00
committed by GitHub
parent 49407169ac
commit 14c4611857
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/SparkBootstrapCommitActionExecutor.java
View File

@@ -284,7 +284,7 @@ public class SparkBootstrapCommitActionExecutor<T extends HoodieRecordPayload<T>
protected BaseSparkCommitActionExecutor<T> getBulkInsertActionExecutor(JavaRDD<HoodieRecord> inputRecordsRDD) { protected BaseSparkCommitActionExecutor<T> getBulkInsertActionExecutor(JavaRDD<HoodieRecord> inputRecordsRDD) {
return new SparkBulkInsertCommitActionExecutor((HoodieSparkEngineContext) context, new HoodieWriteConfig.Builder().withProps(config.getProps()) return new SparkBulkInsertCommitActionExecutor((HoodieSparkEngineContext) context, new HoodieWriteConfig.Builder().withProps(config.getProps())
.withSchema(bootstrapSchema).build(), table, HoodieTimeline.FULL_BOOTSTRAP_INSTANT_TS, .withSchema(bootstrapSchema).build(), table, HoodieTimeline.FULL_BOOTSTRAP_INSTANT_TS,
inputRecordsRDD, extraMetadata); inputRecordsRDD, Option.empty(), extraMetadata);
} }
private BootstrapWriteStatus handleMetadataBootstrap(String srcPartitionPath, String partitionPath, private BootstrapWriteStatus handleMetadataBootstrap(String srcPartitionPath, String partitionPath,