[FLINK-19823] Integrate Filesystem and Hive connector with changelog format (e.g. debezium-json)

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.0
• Component/s: Connectors / FileSystem, Connectors / Hive, Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / Ecosystem
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: Jark Wu
• Created: 27/Oct/20 07:50
• Updated: 07/Nov/20 11:18
• Resolved: 07/Nov/20 11:18

Description

Once Filesystem and Hive have been migrated to FLIP-95 interfaces, it should be possible to integrate with changelog format (e.g. debezium-json and canal-json) in source and sink. We should add tests for that.

Issue Links

• is blocked by: FLINK-19868 Csv Serialization schema contains line delimiter
• links to: GitHub Pull Request #13957