address comment

pingcap · Aug 10, 2021 · fc58f2c · fc58f2c
1 parent ca4f082
commit fc58f2c
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/cdc/sink/mysql.go b/cdc/sink/mysql.go
@@ -885,7 +885,6 @@ func (s *mysqlSink) Barrier(ctx context.Context) error {
 		case <-ctx.Done():
 			return errors.Trace(ctx.Err())
 		case <-ticker.C:
-			ticker.Reset(warnDuration)
 			log.Warn("Barrier doesn't return in time, may be stuck",
 				zap.Uint64("resolved-ts", atomic.LoadUint64(&s.maxResolvedTs)),
 				zap.Uint64("checkpoint-ts", s.checkpointTs()))