fix

Author: LsomeYeah

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java

@@ -321,12 +321,10 @@ private boolean buildForIncrementalClustering(
                                             compactUnits.entrySet().stream()
                                                     .collect(
                                                             Collectors.toMap(
-                                                                    Map.Entry
-                                                                            ::getKey, // 保持原有的BinaryRow键
+                                                                    Map.Entry::getKey,
                                                                     unit ->
                                                                             unit.getValue()
-                                                                                    .outputLevel() // 提取CompactUnit中的level值
-                                                                    ))));
+                                                                                    .outputLevel()))));
             dataStreams.add(clusterCommittable);
             dataStreams.add(sourcePair.getRight());
         }

paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/cluster/RewriteIncrementalClusterCommittableOperator.java

@@ -38,10 +38,7 @@
 
 import static org.apache.paimon.utils.Preconditions.checkArgument;
 
-/**
- * Rewrite committable from postpone bucket table compactor. It moves all new files into compact
- * results, and delete unused new files, because compactor only produce compact snapshots.
- */
+/** Rewrite committable for new files written after clustered. */
 public class RewriteIncrementalClusterCommittableOperator
         extends BoundedOneInputOperator<Committable, Committable> {
     private static final long serialVersionUID = 1L;