diff --git a/fe/src/main/java/org/apache/doris/clone/ColocateTableBalancer.java b/fe/src/main/java/org/apache/doris/clone/ColocateTableBalancer.java index 6b89b8f56a..dc0b069c27 100644 --- a/fe/src/main/java/org/apache/doris/clone/ColocateTableBalancer.java +++ b/fe/src/main/java/org/apache/doris/clone/ColocateTableBalancer.java @@ -572,7 +572,8 @@ public class ColocateTableBalancer extends Daemon { Long cloneReplicaBackendId = newGroup2BackendsPerBucketSeq.get(groupId, i); if (cloneReplicaBackendId == null) { - cloneReplicaBackendId = addedBackendIds.get(i / bucketSeqsPerNewBackend); + // select dest backend + cloneReplicaBackendId = addedBackendIds.get(i % addedBackendIds.size()); newGroup2BackendsPerBucketSeq.put(groupId, i, cloneReplicaBackendId); }