From 7dfbd9e3a520fa7b8e486b7088c940755967af15 Mon Sep 17 00:00:00 2001 From: 3AceShowHand Date: Tue, 14 Jun 2022 11:36:18 +0800 Subject: [PATCH] remove scheduler log. --- cdc/scheduler/internal/tp/scheduler_rebalance.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/cdc/scheduler/internal/tp/scheduler_rebalance.go b/cdc/scheduler/internal/tp/scheduler_rebalance.go index 6b3bdd9eb0e..7ea197581a0 100644 --- a/cdc/scheduler/internal/tp/scheduler_rebalance.go +++ b/cdc/scheduler/internal/tp/scheduler_rebalance.go @@ -22,7 +22,6 @@ import ( "github.com/pingcap/log" "github.com/pingcap/tiflow/cdc/model" - "go.uber.org/zap" ) var _ scheduler = &rebalanceScheduler{} @@ -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)