[jira] [Updated] (FLINK-35119) UPDATE DataChangeEvent deserialized data is incorrect
[ 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)
[jira] [Updated] (FLINK-35119) UPDATE DataChangeEvent deserialized data is incorrect
[ https://issues.apache.org/jira/browse/FLINK-35119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35119: --- Labels: pull-request-available (was: ) > 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, meta) > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Updated] (FLINK-35119) UPDATE DataChangeEvent deserialized data is incorrect
[ 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, 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 > > 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)