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

Numeric arrays not handled correctly

    Details

      Description

      I have a table with a numeric array column defined as numeric_array NUMERIC(10, 2)[]

      When I start the connector on this table I get the following Exception:

      org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type BYTES: class org.apache.kafka.connect.data.Struct for field: "null"
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:239)
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:209)
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:253)
      	at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:209)
      	at org.apache.kafka.connect.data.Struct.put(Struct.java:214)
      	at io.debezium.relational.TableSchemaBuilder.lambda$createValueGenerator$2(TableSchemaBuilder.java:198)
      	at io.debezium.relational.TableSchema.valueFromColumnData(TableSchema.java:111)
      	at io.debezium.connector.postgresql.RecordsSnapshotProducer.generateReadRecord(RecordsSnapshotProducer.java:295)
      	at io.debezium.connector.postgresql.RecordsSnapshotProducer.readTable(RecordsSnapshotProducer.java:255)
      	at io.debezium.connector.postgresql.RecordsSnapshotProducer.lambda$null$39(RecordsSnapshotProducer.java:194)
      	at io.debezium.jdbc.JdbcConnection.query(JdbcConnection.java:389)
      	at io.debezium.connector.postgresql.RecordsSnapshotProducer.lambda$takeSnapshot$40(RecordsSnapshotProducer.java:192)
      	at java.util.concurrent.ConcurrentHashMap$KeySpliterator.forEachRemaining(ConcurrentHashMap.java:3527)
      	at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:580)
      	at io.debezium.connector.postgresql.RecordsSnapshotProducer.takeSnapshot(RecordsSnapshotProducer.java:180)
      	at io.debezium.connector.postgresql.RecordsSnapshotProducer.lambda$start$34(RecordsSnapshotProducer.java:80)
      	at java.util.concurrent.CompletableFuture$AsyncRun.run$$$capture(CompletableFuture.java:1626)
      	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java)
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      	at java.lang.Thread.run(Thread.java:745)
      

        Gliffy Diagrams

          Attachments

            Activity

              People

              • Assignee:
                jpechanec Jiri Pechanec
                Reporter:
                fabrizio.fortino Fabrizio Fortino
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: