diff --git a/ams/server/src/main/java/com/netease/arctic/server/optimizing/plan/MixedIcebergPartitionPlan.java b/ams/server/src/main/java/com/netease/arctic/server/optimizing/plan/MixedIcebergPartitionPlan.java index 1c2730b47a..5d5f3fda4a 100644 --- a/ams/server/src/main/java/com/netease/arctic/server/optimizing/plan/MixedIcebergPartitionPlan.java +++ b/ams/server/src/main/java/com/netease/arctic/server/optimizing/plan/MixedIcebergPartitionPlan.java @@ -155,7 +155,7 @@ public boolean isMinorNecessary() { if (keyedTable) { int smallFileCount = fragmentFileCount + equalityDeleteFileCount; int baseSplitCount = getBaseSplitCount(); - if (smallFileCount >= Math.max(baseSplitCount, config.getMinorLeastFileCount())) { + if (smallFileCount >= Math.max(baseSplitCount + 1, config.getMinorLeastFileCount())) { return true; } else if ((smallFileCount > baseSplitCount || hasChangeFiles) && reachMinorInterval()) { return true;