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

[Colocate Table] Fix colocate table balance forever (#2744)

Browse Source
This commit is contained in:
kangkaisen
2020-01-13 23:13:58 +08:00
committed by Mingyu Chen
parent 273edced77
commit 1ccd377b33
1 changed files with 1 additions and 2 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

@ -149,8 +149,8 @@ public class ColocateTableBalancer extends MasterDaemon {
// But in previous version we had a bug that replicas of a tablet may be located on same host.
// we have to check it.
List<List<Long>> backendsPerBucketsSeq = colocateIndex.getBackendsPerBucketSeq(groupId);
Set<String> hosts = Sets.newHashSet();
OUT: for (List<Long> backendIds : backendsPerBucketsSeq) {
Set<String> hosts = Sets.newHashSet();
for (Long beId : backendIds) {
Backend be = infoService.getBackend(beId);
if (be == null) {
@ -171,7 +171,6 @@ public class ColocateTableBalancer extends MasterDaemon {
continue;
}
}
Preconditions.checkState(unavailableBeId != -1);
// find the first bucket which contains the unavailable backend
LOG.info("backend {} is unavailable in colocate group {}", unavailableBeId, groupId);