sink(ticdc): reduce log print when using CDC sync data to Kafka with …

…nil values in column (#11541) close #11537
pingcap · Sep 13, 2024 · 45c831a · 45c831a
1 parent e374334
commit 45c831a
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/cdc/model/sink.go b/cdc/model/sink.go
@@ -488,15 +488,17 @@ func columnDatas2Columns(cols []*ColumnData, tableInfo *TableInfo) []*Column {
 		return nil
 	}
 	columns := make([]*Column, len(cols))
+	nilColumnNum := 0
 	for i, colData := range cols {
 		if colData == nil {
-			log.Warn("meet nil column data, should not happened in production env",
-				zap.Any("cols", cols),
-				zap.Any("tableInfo", tableInfo))
+			nilColumnNum++
 			continue
 		}
 		columns[i] = columnData2Column(colData, tableInfo)
 	}
+	log.Debug("meet nil column data",
+		zap.Any("nilColumnNum", nilColumnNum),
+		zap.Any("tableInfo", tableInfo))
 	return columns
 }