diff --git a/fe/fe-core/src/main/java/org/apache/doris/clone/TwoDimensionalGreedyRebalanceAlgo.java b/fe/fe-core/src/main/java/org/apache/doris/clone/TwoDimensionalGreedyRebalanceAlgo.java index 05e7528336..3acd3bd9b8 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/clone/TwoDimensionalGreedyRebalanceAlgo.java +++ b/fe/fe-core/src/main/java/org/apache/doris/clone/TwoDimensionalGreedyRebalanceAlgo.java @@ -288,8 +288,13 @@ public class TwoDimensionalGreedyRebalanceAlgo { */ public static boolean applyMove(PartitionMove move, TreeMultimap beByTotalReplicaCount, TreeMultimap skewMap) { - // Update the total counts - moveOneReplica(move.fromBe, move.toBe, beByTotalReplicaCount); + try { + // Update the total counts + moveOneReplica(move.fromBe, move.toBe, beByTotalReplicaCount); + } catch (IllegalStateException e) { + LOG.info("{} apply failed, {}", move, e.getMessage()); + return false; + } try { PartitionBalanceInfo partitionBalanceInfo = null;