[FLINK-20885] Deserialization exception when using 'canal-json.table.include' to filter out the binlog of the specified table

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / Ecosystem
• Labels: pull-request-available
• Assignee: Nicholas Jiang
• Reporter: Jark Wu
• Created: 07/Jan/21 10:20
• Updated: 14/Jan/21 14:05
• Resolved: 14/Jan/21 14:05

Description

I found a bug in the canal code. 'canal-json.table.include' does not filter out the binlog of the specified table correctly, which will cause an error in the parsing section. For example, if I want to read the binlog of canal-json.table.include = 'a' table, there is a source field of int in table a, but at this time if table b also has a source field of string, An error will be reported.

Issue Links

• links to: GitHub Pull Request #14631