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)
