diff --git a/cdc/processor.go b/cdc/processor.go index e8364af5b10..23f1176828b 100644 --- a/cdc/processor.go +++ b/cdc/processor.go @@ -966,7 +966,7 @@ func (p *processor) addTable(ctx context.Context, tableID int64, replicaInfo *mo if table, ok := p.tables[tableID]; ok { if atomic.SwapUint32(&table.isDying, 0) == 1 { - log.Warn("The same table exists but is dying. Cancel it and continue.", util.ZapFieldChangefeed(ctx), zap.Int64("ID", tableID)) + log.Panic("The same table exists but is dying. Cancel it and continue.", util.ZapFieldChangefeed(ctx), zap.Int64("ID", tableID)) table.cancel() } else { log.Warn("Ignore existing table", util.ZapFieldChangefeed(ctx), zap.Int64("ID", tableID))