[FLINK-18700] Debezium-json format throws Exception when PG table's IDENTITY config is not FULL

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.11.0, 1.11.1
• Fix Version/s: 1.12.0, 1.11.2
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / Ecosystem
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Leonard Xu
• Created: 24/Jul/20 08:15
• Updated: 31/Jul/20 11:48
• Resolved: 31/Jul/20 11:48

Description

If the cdc data comes from a PG table and the PG table's IDENTITY config is not FULL，

the UPDATE changelog's update message will be null lead a NPE error.

We can add document to remind user set proper  IDENTITY for PG table in debezium doc

and improve the Exception message.

 

It's reported in http://apache-flink.147419.n8.nabble.com/flink-1-11-cdc-td5298.html

Issue Links

• links to: GitHub Pull Request #13019