Skip to content

Commit

Permalink
remove scheduler log.
Browse files Browse the repository at this point in the history
  • Loading branch information
3AceShowHand committed Jun 14, 2022
1 parent 5ce736d commit 7dfbd9e
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions cdc/scheduler/internal/tp/scheduler_rebalance.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ import (

"github.com/pingcap/log"
"github.com/pingcap/tiflow/cdc/model"
"go.uber.org/zap"
)

var _ scheduler = &rebalanceScheduler{}
Expand Down Expand Up @@ -93,9 +92,6 @@ func newBurstBalanceMoveTables(

for tableID, rep := range replications {
if rep.State != ReplicationSetStateReplicating {
log.Info("tpscheduler: rebalance skip tables that are not in Replicating",
zap.Int64("tableID", tableID),
zap.Any("replication", rep))
continue
}
tablesPerCapture[rep.Primary].add(tableID)
Expand Down

0 comments on commit 7dfbd9e

Please sign in to comment.