panic when adding a dying table

pingcap · Dec 29, 2020 · a05b81a · a05b81a
1 parent 8681553
commit a05b81a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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))