fix

LsomeYeah · LsomeYeah · commit 6a7b5d7906bd · 2026-03-03T10:06:57.000+08:00
diff --git a/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java b/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java
@@ -3409,7 +3409,7 @@ public boolean clusteringIncrementalEnabled() {
         return options.get(CLUSTERING_INCREMENTAL);
     }
 
-    public boolean preClusteringEnabled() {
+    public boolean clusteringIncrementalOptimizeWrite() {
         return options.get(CLUSTERING_INCREMENTAL_OPTIMIZE_WRITE);
     }
 
diff --git a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonSparkWriter.scala b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/PaimonSparkWriter.scala
@@ -305,7 +305,7 @@ case class PaimonSparkWriter(
         val clusteringColumns = coreOptions.clusteringColumns()
         if (
           (!coreOptions.clusteringIncrementalEnabled() || coreOptions
-            .preClusteringEnabled()) && (!clusteringColumns.isEmpty)
+            .clusteringIncrementalOptimizeWrite()) && (!clusteringColumns.isEmpty)
         ) {
           val strategy = coreOptions.clusteringStrategy(tableSchema.fields().size())
           val sorter = TableSorter.getSorter(table, strategy, clusteringColumns)

Original file line number	Diff line number	Diff line change
`@@ -3409,7 +3409,7 @@ public boolean clusteringIncrementalEnabled() {`
`3409`	`3409`	`return options.get(CLUSTERING_INCREMENTAL);`
`3410`	`3410`	`}`
`3411`	`3411`
`3412`		`- public boolean preClusteringEnabled() {`
	`3412`	`+ public boolean clusteringIncrementalOptimizeWrite() {`
`3413`	`3413`	`return options.get(CLUSTERING_INCREMENTAL_OPTIMIZE_WRITE);`
`3414`	`3414`	`}`
`3415`	`3415`