change log.Panic to log.Error

pingcap · May 17, 2022 · 921e72f · 921e72f
1 parent 756553f
commit 921e72f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cdc/model/sink.go b/cdc/model/sink.go
@@ -323,7 +323,7 @@ func (r *RowChangedEvent) HandleKeyColumns() []*Column {
 	}
 
 	if len(pkeyCols) == 0 {
-		log.Panic("Cannot find handle key columns.", zap.Any("event", r))
+		log.Error("Cannot find handle key columns.", zap.Any("event", r))
 	}
 
 	return pkeyCols
@@ -349,7 +349,7 @@ func (r *RowChangedEvent) HandleKeyColInfos() ([]*Column, []rowcodec.ColInfo) {
 	}
 
 	if len(pkeyCols) == 0 {
-		log.Panic("Cannot find handle key columns.", zap.Any("event", r))
+		log.Error("Cannot find handle key columns.", zap.Any("event", r))
 	}
 
 	return pkeyCols, pkeyColInfos