database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

Fix colocate join balance bug (#547)

Browse Source
This commit is contained in:
kangkaisen
2019-01-17 14:58:08 +08:00
committed by Mingyu Chen
parent 6bef41633c
commit 5cb1c161a4
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
fe/src/main/java/org/apache/doris/clone/ColocateTableBalancer.java
View File

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