This is an automated email from the ASF dual-hosted git repository. dataroaring pushed a commit to branch branch-1.2-lts in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.2-lts by this push: new ddbc9eeb47 [fix](tablet clone) fix partition rebalance apply move exception (#23222) (#23808) ddbc9eeb47 is described below commit ddbc9eeb47a607f46ec2e61dd08d0df77dd5452e Author: yujun <yu.jun.re...@gmail.com> AuthorDate: Mon Sep 4 11:52:22 2023 +0800 [fix](tablet clone) fix partition rebalance apply move exception (#23222) (#23808) --- .../apache/doris/clone/TwoDimensionalGreedyRebalanceAlgo.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) 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<Long, Long> beByTotalReplicaCount, TreeMultimap<Long, PartitionBalanceInfo> 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; --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org