From a05b81a23fce13a0ebaaaee1910284f79f93c5a2 Mon Sep 17 00:00:00 2001 From: leoppro Date: Tue, 29 Dec 2020 17:39:50 +0800 Subject: [PATCH] panic when adding a dying table --- cdc/processor.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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))