diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java index 4d07097c07c8..020328277a5e 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java @@ -311,7 +311,7 @@ public class HoodieWriteConfig extends HoodieConfig { public static final ConfigProperty BULK_INSERT_SORT_MODE = ConfigProperty .key("hoodie.bulkinsert.sort.mode") - .defaultValue(BulkInsertSortMode.GLOBAL_SORT.toString()) + .defaultValue(BulkInsertSortMode.NONE.toString()) .withDocumentation("Sorting modes to use for sorting records for bulk insert. This is use when user " + BULKINSERT_USER_DEFINED_PARTITIONER_CLASS_NAME.key() + "is not configured. Available values are - " + "GLOBAL_SORT: this ensures best file sizes, with lowest memory overhead at cost of sorting. " diff --git a/hudi-common/src/main/java/org/apache/hudi/common/config/HoodieCommonConfig.java b/hudi-common/src/main/java/org/apache/hudi/common/config/HoodieCommonConfig.java index 917cfe621f11..34734bd4f8ca 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/config/HoodieCommonConfig.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/config/HoodieCommonConfig.java @@ -38,7 +38,7 @@ public class HoodieCommonConfig extends HoodieConfig { public static final ConfigProperty RECONCILE_SCHEMA = ConfigProperty .key("hoodie.datasource.write.reconcile.schema") - .defaultValue(false) + .defaultValue(true) .withDocumentation("When a new batch of write has records with old schema, but latest table schema got " + "evolved, this config will upgrade the records to leverage latest table schema(default values will be " + "injected to missing fields). If not, the write batch would fail."); diff --git a/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/BaseProcedure.scala b/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/BaseProcedure.scala index 876bb503ee19..4c7687f7c413 100644 --- a/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/BaseProcedure.scala +++ b/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/BaseProcedure.scala @@ -50,7 +50,7 @@ abstract class BaseProcedure extends Procedure { HoodieWriteConfig.newBuilder .withPath(basePath) .withIndexConfig(HoodieIndexConfig.newBuilder.withIndexType(IndexType.BLOOM).build) - .withRollbackUsingMarkers(false) + .withRollbackUsingMarkers(HoodieWriteConfig.ROLLBACK_USING_MARKERS_ENABLE.defaultValue.toBoolean) .build }