Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-4941

null value comes from non nullable column

    XMLWordPrintable

Details

    • False
    • None
    • False

    Description

      hi theres 

      When importing data from postgresql, sometimes the following specific error occurs.

       

      Caused by: org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field: "external_invoice_urls", schema type: ARRAY
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:220)
      	at org.apache.kafka.connect.data.Struct.validate(Struct.java:233)
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:253)
      	at org.apache.kafka.connect.data.Struct.put(Struct.java:216)
      	at org.apache.kafka.connect.data.Struct.put(Struct.java:203)
      	at io.debezium.data.Envelope.update(Envelope.java:323)
      	at io.debezium.relational.RelationalChangeRecordEmitter.emitUpdateRecord(RelationalChangeRecordEmitter.java:111)
      	at io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:52)
      	at io.debezium.connector.postgresql.PostgresChangeRecordEmitter.emitChangeRecords(PostgresChangeRecordEmitter.java:97)
      	at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:215)
      	... 17 more 

       

      Since the external_invoice_urls column is a non-nullable value, there is no default value, and shouldn't a value always be passed in?

       

      heres is table schema 

      SELECT column_name, is_nullable, data_type
      FROM information_schema.COLUMNS
      WHERE TABLE_NAME = 'reservations'; 

       

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            jaegwon.seo wornjs seo
            Votes:
            2 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated: