Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-18700

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

    XMLWordPrintableJSON

    Details

      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

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                jark Jark Wu
                Reporter:
                Leonard Xu Leonard Xu
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: