You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "CaoZhen (Jira)" <ji...@apache.org> on 2020/10/04 09:04:00 UTC
[jira] [Created] (FLINK-19500) Using canal-json,debezium-json,maxwell-json serialization, The DELETE semantics should be interpreted.
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)