[ https://issues.apache.org/jira/browse/FLINK-18824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-18824: ----------------------------------- Labels: pull-request-available (was: ) > Support serialization for canal-json format > ------------------------------------------- > > Key: FLINK-18824 > URL: https://issues.apache.org/jira/browse/FLINK-18824 > Project: Flink > Issue Type: Sub-task > Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table > SQL / Ecosystem > Reporter: Jark Wu > Assignee: CaoZhen > Priority: Major > Labels: pull-request-available > > Currently, canal-json format only support deserialization, but not support > serialization. This is not convenient for users to writing changelogs to an > message queue. > The serialization for canal-json can follow the json strcuture of Canal, but > considering currently Flink can't combine UPDATE_BEFORE and UPDATE_AFTER into > a single UPDATE message. We can encode UPDATE_BEFORE and UDPATE_AFTER as > DELETE and INSERT canal messages. -- This message was sent by Atlassian Jira (v8.3.4#803005)