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);