From 5cb1c161a4e84b4c7de96dd4a01d8463b4a76dd2 Mon Sep 17 00:00:00 2001
From: kangkaisen <kangkaisen@163.com>
Date: Thu, 17 Jan 2019 14:58:08 +0800
Subject: [PATCH] Fix colocate join balance bug (#547)

---
 .../java/org/apache/doris/clone/ColocateTableBalancer.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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);
                             }