This is an automated email from the ASF dual-hosted git repository. yihua pushed a commit to branch release-0.15.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 9e79996a48b50bc2a136fc477d453cc2193e51fe Author: Sivabalan Narayanan <[email protected]> AuthorDate: Wed May 29 15:02:40 2024 -0700 [HUDI-7812] Disabling row writer for clustering (#11360) --- .../clustering/run/strategy/MultipleSparkJobExecutionStrategy.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/MultipleSparkJobExecutionStrategy.java b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/MultipleSparkJobExecutionStrategy.java index 976795b7dc6..eb59397b328 100644 --- a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/MultipleSparkJobExecutionStrategy.java +++ b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/MultipleSparkJobExecutionStrategy.java @@ -119,7 +119,7 @@ public abstract class MultipleSparkJobExecutionStrategy<T> Stream<HoodieData<WriteStatus>> writeStatusesStream = FutureUtils.allOf( clusteringPlan.getInputGroups().stream() .map(inputGroup -> { - if (getWriteConfig().getBooleanOrDefault("hoodie.datasource.write.row.writer.enable", true)) { + if (getWriteConfig().getBooleanOrDefault("hoodie.datasource.write.row.writer.enable", false)) { return runClusteringForGroupAsyncAsRow(inputGroup, clusteringPlan.getStrategy().getStrategyParams(), shouldPreserveMetadata,
