Skip to content

Commit

Permalink
[MINOR] Fixing usage of right config value for parallelism to dedup i…
Browse files Browse the repository at this point in the history
…n Bulk Insert (apache#1905)
  • Loading branch information
nsivabalan authored Aug 3, 2020
1 parent 433d7d2 commit 266bce1
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public static <T extends HoodieRecordPayload<T>> HoodieWriteMetadata bulkInsert(

if (performDedupe) {
dedupedRecords = WriteHelper.combineOnCondition(config.shouldCombineBeforeInsert(), inputRecords,
config.getInsertShuffleParallelism(), ((HoodieTable<T>)table));
config.getBulkInsertShuffleParallelism(), ((HoodieTable<T>)table));
}

final JavaRDD<HoodieRecord<T>> repartitionedRecords;
Expand Down

0 comments on commit 266bce1

Please sign in to comment.