From 1ccd377b336ef9dcdacd9d2805a27be380ef2d64 Mon Sep 17 00:00:00 2001
From: kangkaisen <kangkaisen@apache.org>
Date: Mon, 13 Jan 2020 23:13:58 +0800
Subject: [PATCH] [Colocate Table] Fix colocate table balance forever (#2744)

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

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 ee5ae73f0b..948cfeea61 100644
--- a/fe/src/main/java/org/apache/doris/clone/ColocateTableBalancer.java
+++ b/fe/src/main/java/org/apache/doris/clone/ColocateTableBalancer.java
@@ -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);