Skip to content

Commit

Permalink
processor/sourcemanager(ticdc): address comment
Browse files Browse the repository at this point in the history
  • Loading branch information
Rustin170506 committed Nov 30, 2022
1 parent 7b8cf0a commit d2757cc
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion cdc/processor/sinkmanager/manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -648,7 +648,7 @@ func (m *SinkManager) GetTableStats(tableID model.TableID) pipeline.Stats {
select {
case m.engineGCChan <- gcEvent:
default:
log.Debug("Failed to send GC event to engine GC channel, engine GC channel is full",
log.Warn("Failed to send GC event to engine GC channel, engine GC channel is full",
zap.String("namespace", m.changefeedID.Namespace),
zap.String("changefeed", m.changefeedID.ID),
zap.Int64("tableID", tableID),
Expand Down

0 comments on commit d2757cc

Please sign in to comment.