fix: miss 'break' in alleviate shard

tkestack · Jun 17, 2022 · bea0c8a · bea0c8a
1 parent b7451df
commit bea0c8a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/coordinator/rebalance.go b/pkg/coordinator/rebalance.go
@@ -302,6 +302,7 @@ func (c *Coordinator) alleviateShard(s *shardInfo, changeAbleShards []*shardInfo
 				c.log.Infof("transfer target from %s to %s series = (%d) ", s.shard.ID, os.shard.ID, tar.Series)
 				transferTarget(s, os, hash)
 				total -= tar.Series
+				break
 			}
 		}
 	}