Jark Wu created FLINK-17150:
-------------------------------
Summary: Introduce Canal format to support reading canal changelogs
Key: FLINK-17150
URL: https://issues.apache.org/jira/browse/FLINK-17150
Project: Flink
Issue Type: Sub-task
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table
SQL / Ecosystem
Reporter: Jark Wu
Fix For: 1.11.0
Introduce CanalFormatFactory and CanalRowDeserializationSchema to read
[canal|https://github.com/alibaba/canal] changelogs.
{code:sql}
CREATE TABLE my_table (
...
) WITH (
'connector'='...', -- e.g. 'kafka'
'format'='canal-json',
'format.ignore-parse-errors'='true' -- default false
);
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
