CaoZhen created FLINK-19500:
-------------------------------
Summary: Using canal-json,debezium-json,maxwell-json
serialization, The DELETE semantics should be interpreted.
Key: FLINK-19500
URL: https://issues.apache.org/jira/browse/FLINK-19500
Project: Flink
Issue Type: Bug
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
Reporter: CaoZhen
When Using {{canal-json}},{{debezium-json}},{{maxwell-json}} serialization, the
RowData of {{DELETE}} was not put {{old}} data into JSON message. I will open
an issue to track it.
*For example，Maxwell-json:*
*the Rowdata：*
-U(106,hammer,16oz carpenter's hammer,1.0)
*active Maxwell-json serialization:*
{
"data":{
"id":106,
"name":"hammer",
"description":"16oz carpenter's hammer",
"weight":1
},
"type":"delete"
}
*expected Maxwell-json serialization:*
{
"old":{
"id":106,
"name":"hammer",
"description":"16oz carpenter's hammer",
"weight":1
},
"data":null,
"type":"delete"
}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
