[
https://issues.apache.org/jira/browse/FLINK-35119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qishang Zhong updated FLINK-35119:
----------------------------------
Description:
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),
DataChangeEvent.updateEvent(
TableId.tableId("namespace", "schema", "table"), null, after, meta)
{code}
was:
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}
> 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
> Priority: Minor
> Labels: pull-request-available
>
> 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),
> DataChangeEvent.updateEvent(
> TableId.tableId("namespace", "schema", "table"), null, after, meta)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
