From 921e72f5a22695c53e275b0e7726e9a1539b24a0 Mon Sep 17 00:00:00 2001 From: zhangyangyu Date: Tue, 17 May 2022 11:45:59 +0800 Subject: [PATCH] change log.Panic to log.Error --- cdc/model/sink.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cdc/model/sink.go b/cdc/model/sink.go index 49f1dc872b5..9b233f85cee 100644 --- 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