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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
