|
|
|
FLINK-20926
|
FLINK-18822
Allow to read metadata for maxwell-json format
|
Nicholas Jiang
|
Q Kang
|
|
Resolved |
Implemented
|
|
|
|
|
|
|
|
FLINK-20454
|
FLINK-18822
Allow to read metadata for debezium-avro-confluent format
|
li mo
|
Jark Wu
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-20421
|
FLINK-18822
Support canal-protobuf format
|
Unassigned
|
Jark Wu
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-20385
|
FLINK-18822
Allow to read metadata for Canal-json format
|
Nicholas Jiang
|
Leonard Xu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-20150
|
FLINK-18822
Add documentation for the debezium-avro format
|
Jark Wu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19873
|
FLINK-18822
Skip DDL change events for Canal data
|
Fangliang Liu
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19795
|
FLINK-18822
Fix Flink SQL throws exception when changelog source contains duplicate change events
|
Jark Wu
|
jinxin
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18897
|
FLINK-18822
Add documentation for the maxwell-json format
|
Shengkai Fang
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18844
|
FLINK-18822
Support maxwell-json format to read Maxwell changelogs
|
jinxin
|
jinxin
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18826
|
FLINK-18822
Support to emit and encode upsert messages to Kafka
|
Unassigned
|
Jark Wu
|
|
Closed |
Duplicate
|
|
|
|
|
|
|
|
FLINK-18825
|
FLINK-18822
Support to process CDC message in batch mode
|
Unassigned
|
Jark Wu
|
|
In Progress |
Unresolved
|
|
|
|
|
|
|
|
FLINK-18824
|
FLINK-18822
Support serialization for canal-json format
|
CaoZhen
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18823
|
FLINK-18822
Support serialization for debezium-json format
|
Nicholas Jiang
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18774
|
FLINK-18822
Support debezium-avro format
|
CaoZhen
|
Jark Wu
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18758
|
FLINK-18822
Many data types do not work in debezium format
|
Unassigned
|
Leonard Xu
|
|
Open |
Unresolved
|
|
|
|
|