try fix

pingcap · Feb 20, 2024 · 4fab31e · 4fab31e
1 parent 7412eb7
commit 4fab31e
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/cdc/redo/reader/reader.go b/cdc/redo/reader/reader.go
@@ -250,10 +250,14 @@ func (l *LogReader) ReadNextRow(ctx context.Context) (*model.RowChangedEvent, er
 				zap.Any("columns", rowInRedoLog.Columns),
 				zap.String("table", rowInRedoLog.Table.Table),
 				zap.String("schema", rowInRedoLog.Table.Schema))
+			cols := rowInRedoLog.Columns
+			if cols == nil {
+				cols = rowInRedoLog.PreColumns
+			}
 			tableInfo := model.BuildTableInfo(
 				rowInRedoLog.Table.Schema,
 				rowInRedoLog.Table.Table,
-				rowInRedoLog.Columns,
+				cols,
 				rowInRedoLog.IndexColumns)
 			tableInfo.TableName.TableID = rowInRedoLog.Table.TableID
 			tableInfo.TableName.IsPartition = rowInRedoLog.Table.IsPartition