Qishang Zhong created FLINK-35119: ------------------------------------- Summary: UPDATE DataChangeEvent deserialized data is incorrect Key: FLINK-35119 URL: https://issues.apache.org/jira/browse/FLINK-35119 Project: Flink Issue Type: Bug Components: Flink CDC Affects Versions: cdc-3.1.0 Reporter: Qishang Zhong
When DebeziumChangelogMode is upsert, the before of DataChangeEvent is null, deserialized data is incorrect. Add test data in org.apache.flink.cdc.runtime.serializer.event.DataChangeEventSerializerTest {code:java} DataChangeEvent.updateEvent( TableId.tableId("namespace", "schema", "table"), null, after, meta) {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)