clea: remove some log

tkestack · May 25, 2021 · 471a688 · 471a688
1 parent f0b4b84
commit 471a688
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/pkg/coordinator/rebalance.go b/pkg/coordinator/rebalance.go
@@ -213,7 +213,6 @@ func (c *Coordinator) alleviateShards(changeAbleShards []*shardInfo) (needSpace
 	for _, s := range changeAbleShards {
 		for _, t := range threshold {
 			if s.runtime.HeadSeries >= seriesWithRate(c.maxSeries, t.maxSeriesRate) {
-				c.log.Infof("%s series is %d, over rate %f", s.shard.ID, s.runtime.HeadSeries, t.maxSeriesRate)
 				needSpace += c.alleviateShard(s, changeAbleShards, seriesWithRate(c.maxSeries, t.expectSeriesRate))
 				break
 			}

diff --git a/pkg/shard/kubernetes/replicasmanager.go b/pkg/shard/kubernetes/replicasmanager.go
@@ -76,7 +76,7 @@ func (g *ReplicasManager) Replicas() ([]shard.Manager, error) {
 			continue
 		}
 
-		if g.stsUpdatedTime[s.Name] == nil {
+		if s.Status.ReadyReplicas != s.Status.Replicas && g.stsUpdatedTime[s.Name] == nil {
 			t := time.Now()
 			g.lg.Warnf("Statefulset %s is not ready, try wait 2m", s.Name)
 			g.stsUpdatedTime[s.Name] = &t