diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java b/hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java index 42ad864ff07b..d205809c8de7 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java @@ -1329,7 +1329,8 @@ public Properties build() { Triple mergeConfigs = HoodieTableConfig.inferCorrectMergingBehavior(recordMergeMode, payloadClassName, recordMergerStrategy); - if (null != cdcEnabled && cdcEnabled && mergeConfigs.getMiddle() == null) { + if (tableConfig.getBootstrapBasePath().isPresent() || + (null != cdcEnabled && cdcEnabled && mergeConfigs.getMiddle() == null)) { tableConfig.setValue(RECORD_MERGE_MODE, RecordMergeMode.CUSTOM.name()); tableConfig.setValue(PAYLOAD_CLASS_NAME.key(), HoodieRecordPayload.getAvroPayloadForMergeMode(mergeConfigs.getLeft())); tableConfig.setValue(RECORD_MERGER_STRATEGY, HoodieRecordMerger.PAYLOAD_BASED_MERGER_STRATEGY_UUDID);