(paimon) branch master updated: [core] Fix compile for CompactTasks

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 652ebc88dd [core] Fix compile for CompactTasks
652ebc88dd is described below

commit 652ebc88dd4732ee4b72ff9ff6ffbe4dabd2721b
Author: JingsongLi <jingsongl...@gmail.com>
AuthorDate: Fri Jul 3 21:22:52 2026 +0800

    [core] Fix compile for CompactTasks
---
 .../java/org/apache/paimon/append/BucketedAppendCompactManager.java   | 4 ++--
 .../apache/paimon/append/cluster/BucketedAppendClusterManager.java    | 2 +-
 .../org/apache/paimon/mergetree/compact/FileRewriteCompactTask.java   | 4 +---
 .../paimon/mergetree/compact/clustering/ClusteringCompactManager.java | 2 +-
 4 files changed, 5 insertions(+), 7 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/append/BucketedAppendCompactManager.java
 
b/paimon-core/src/main/java/org/apache/paimon/append/BucketedAppendCompactManager.java
index 93f09c42f3..71cebe7f7a 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/append/BucketedAppendCompactManager.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/append/BucketedAppendCompactManager.java
@@ -257,7 +257,7 @@ public class BucketedAppendCompactManager extends 
CompactFutureManager {
                 boolean forceRewriteAllFiles,
                 CompactRewriter rewriter,
                 @Nullable CompactionMetrics.Reporter metricsReporter) {
-            super(metricsReporter);
+            super(metricsReporter, "");
             this.dvMaintainer = dvMaintainer;
             this.toCompact = new LinkedList<>(inputs);
             this.compactionFileSize = compactionFileSize;
@@ -326,7 +326,7 @@ public class BucketedAppendCompactManager extends 
CompactFutureManager {
                 List<DataFileMeta> toCompact,
                 CompactRewriter rewriter,
                 @Nullable CompactionMetrics.Reporter metricsReporter) {
-            super(metricsReporter);
+            super(metricsReporter, "");
             this.dvMaintainer = dvMaintainer;
             this.toCompact = toCompact;
             this.rewriter = rewriter;
diff --git 
a/paimon-core/src/main/java/org/apache/paimon/append/cluster/BucketedAppendClusterManager.java
 
b/paimon-core/src/main/java/org/apache/paimon/append/cluster/BucketedAppendClusterManager.java
index 154d10c9d3..c223084d31 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/append/cluster/BucketedAppendClusterManager.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/append/cluster/BucketedAppendClusterManager.java
@@ -193,7 +193,7 @@ public class BucketedAppendClusterManager extends 
CompactFutureManager {
 
         public BucketedAppendClusterTask(
                 List<DataFileMeta> toCluster, int outputLevel, CompactRewriter 
rewriter) {
-            super(null);
+            super(null, "");
             this.toCluster = toCluster;
             this.outputLevel = outputLevel;
             this.rewriter = rewriter;
diff --git 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FileRewriteCompactTask.java
 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FileRewriteCompactTask.java
index 686f640d49..6b94da51f4 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FileRewriteCompactTask.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/FileRewriteCompactTask.java
@@ -38,7 +38,6 @@ public class FileRewriteCompactTask extends CompactTask {
     private final int outputLevel;
     private final List<DataFileMeta> files;
     private final boolean dropDelete;
-    private final String bucketInfo;
 
     public FileRewriteCompactTask(
             CompactRewriter rewriter,
@@ -46,12 +45,11 @@ public class FileRewriteCompactTask extends CompactTask {
             boolean dropDelete,
             @Nullable CompactionMetrics.Reporter metricsReporter,
             String bucketInfo) {
-        super(metricsReporter);
+        super(metricsReporter, bucketInfo);
         this.rewriter = rewriter;
         this.outputLevel = unit.outputLevel();
         this.files = unit.files();
         this.dropDelete = dropDelete;
-        this.bucketInfo = bucketInfo;
     }
 
     @Override
diff --git 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/clustering/ClusteringCompactManager.java
 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/clustering/ClusteringCompactManager.java
index 5f905d9b25..276c02a00d 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/clustering/ClusteringCompactManager.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/clustering/ClusteringCompactManager.java
@@ -184,7 +184,7 @@ public class ClusteringCompactManager extends 
CompactFutureManager {
         }
         taskFuture =
                 executor.submit(
-                        new CompactTask(metricsReporter) {
+                        new CompactTask(metricsReporter, "") {
                             @Override
                             protected CompactResult doCompact() throws 
Exception {
                                 return compact(fullCompaction);