Leonard Xu created FLINK-18700:
----------------------------------
Summary: Debezium-json format throws Exception when PG table's
IDENTITY config is not FULL
Key: FLINK-18700
URL: https://issues.apache.org/jira/browse/FLINK-18700
Project: Flink
Issue Type: Bug
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
Affects Versions: 1.11.1, 1.11.0
Reporter: Leonard Xu
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]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
