use avro merge for bootstrap

jonvex · Oct 7, 2024 · 69602dc · 69602dc
1 parent 46e7e53
commit 69602dc
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -1329,7 +1329,8 @@ public Properties build() {
       Triple<RecordMergeMode, String, String> 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);