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

lzljs3620320 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 eff10ccde5 [core] Rename to forceKeepDelete in MergeTreeCompactManager
eff10ccde5 is described below

commit eff10ccde5318660bab024551e42da8258fbaa24
Author: JingsongLi <[email protected]>
AuthorDate: Sat Jan 17 20:42:49 2026 +0800

    [core] Rename to forceKeepDelete in MergeTreeCompactManager
---
 .../apache/paimon/mergetree/compact/MergeTreeCompactManager.java | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java
 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java
index 6160f74e2f..ee431f4e03 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/mergetree/compact/MergeTreeCompactManager.java
@@ -68,11 +68,10 @@ public class MergeTreeCompactManager extends 
CompactFutureManager {
     private final boolean lazyGenDeletionFile;
     private final boolean needLookup;
     private final boolean forceRewriteAllFiles;
+    private final boolean forceKeepDelete;
 
     @Nullable private final RecordLevelExpire recordLevelExpire;
 
-    private final boolean keepDelete;
-
     public MergeTreeCompactManager(
             ExecutorService executor,
             Levels levels,
@@ -87,7 +86,7 @@ public class MergeTreeCompactManager extends 
CompactFutureManager {
             boolean needLookup,
             @Nullable RecordLevelExpire recordLevelExpire,
             boolean forceRewriteAllFiles,
-            boolean keepDelete) {
+            boolean forceKeepDelete) {
         this.executor = executor;
         this.levels = levels;
         this.strategy = strategy;
@@ -101,7 +100,7 @@ public class MergeTreeCompactManager extends 
CompactFutureManager {
         this.recordLevelExpire = recordLevelExpire;
         this.needLookup = needLookup;
         this.forceRewriteAllFiles = forceRewriteAllFiles;
-        this.keepDelete = keepDelete;
+        this.forceKeepDelete = forceKeepDelete;
 
         MetricUtils.safeCall(this::reportMetrics, LOG);
     }
@@ -178,7 +177,7 @@ public class MergeTreeCompactManager extends 
CompactFutureManager {
                      * See CompactStrategy.pick.
                      */
                     boolean dropDelete =
-                            !keepDelete
+                            !forceKeepDelete
                                     && unit.outputLevel() != 0
                                     && (unit.outputLevel() >= 
levels.nonEmptyHighestLevel()
                                             || dvMaintainer != null);

Reply via email to