Skip to content

Commit 072b6f8

Browse files
author
王俊博(wangjunbo)
committed
[FLINK-38197][cdc-common] Fix Data Errors Caused by Default Added Columns at End Position
1 parent 998e023 commit 072b6f8

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivator.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -290,7 +290,9 @@ private static Stream<SchemaChangeEvent> lenientizeAddColumnEvent(
290290
.nullable(),
291291
col.getAddColumn().getComment(),
292292
col.getAddColumn()
293-
.getDefaultValueExpression())))
293+
.getDefaultValueExpression()),
294+
col.getPosition(),
295+
col.getExistedColumnName()))
294296
.collect(Collectors.toList())));
295297
}
296298

0 commit comments

Comments
 (0)