This is an automated email from the ASF dual-hosted git repository. dataroaring pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push: new f0bc2c2eff [fix](tablet clone) fix partition rebalance apply move exception (#23222) f0bc2c2eff is described below commit f0bc2c2effe7d4369743006fec79ed7c31da2123 Author: yujun <yu.jun.re...@gmail.com> AuthorDate: Wed Aug 23 21:50:50 2023 +0800 [fix](tablet clone) fix partition rebalance apply move exception (#23222) --- .../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