LvYanquan created FLINK-36263:
---------------------------------
Summary: 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: LvYanquan
Fix For: cdc-3.3.0
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)
