[
https://issues.apache.org/jira/browse/FLINK-36263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanquan Lv updated FLINK-36263:
-------------------------------
Fix Version/s: (was: cdc-3.4.0)
> Include only changed columns in old for canal format in Kakfa Sink
> ------------------------------------------------------------------
>
> Key: FLINK-36263
> URL: https://issues.apache.org/jira/browse/FLINK-36263
> Project: Flink
> Issue Type: New Feature
> Components: Flink CDC
> Affects Versions: cdc-3.3.0
> Reporter: Yanquan Lv
> Priority: Minor
>
> For Update type events, in Canal's official implementation, the old field
> only contains the modified column data.
> An example output that only c_int and c_tinyint columns were changed:
> {code:java}
> {
> "id": 0,
> ...
> "type": "UPDATE",
> ...
> "sqlType": {
> ...
> },
> "mysqlType": {
> ...
> },
> "data": [
> {
> "c_bigint": "9223372036854775807",
> "c_int": "0",
> "c_mediumint": "8388607",
> "c_smallint": "32767",
> "c_tinyint": "0",
> "id": "2"
> }
> ],
> "old": [
> {
> "c_int": "2147483647",
> "c_tinyint": "127"
> }
> ]
> } {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
