Aiven-Open / Aiven-Open/jdbc-connector-for-apache-kafka

Unable to process numeric types

Offen
#100 0 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
Vorherrschende Sprache
Java
Sterne
113
Forks
62
Ø Merge
4 Std. 12 Min.
Gemergte PRs (30 T.)
1

Beschreibung

When trying to process numeric types I receive the following stack trace.

`
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 -org.postgresql.util.PSQLException: Bad value for type BigDecimal : 0.05
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at org.postgresql.jdbc.PgResultSet.scaleBigDecimal(PgResultSet.java:2913)
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at org.postgresql.jdbc.PgResultSet.getNumeric(PgResultSet.java:2350)
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at org.postgresql.jdbc.PgResultSet.getBigDecimal(PgResultSet.java:2314)
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at io.aiven.connect.jdbc.dialect.GenericDatabaseDialect.lambda$columnConverterFor$20(GenericDatabaseDialect.java:1181)
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at io.aiven.connect.jdbc.source.SchemaMapping$FieldSetter.setField(SchemaMapping.java:161)
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at io.aiven.connect.jdbc.source.TimestampIncrementingTableQuerier.extractRecord(TimestampIncrementingTableQuerier.java:197)
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at io.aiven.connect.jdbc.source.JdbcSourceTask.poll(JdbcSourceTask.java:326)
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:291)
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:248)
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:189)
17 Sep 2021 16:41:02.476tm-staging-selachii-db-kafka-connect-4 - at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:238)
17 Sep 2021 16:41:02.477tm-staging-selachii-db-kafka-connect-4 - at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
17 Sep 2021 16:41:02.477tm-staging-selachii-db-kafka-connect-4 - at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
17 Sep 2021 16:41:02.477tm-staging-selachii-db-kafka-connect-4 - at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
17 Sep 2021 16:41:02.477tm-staging-selachii-db-kafka-connect-4 - at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)`

I suspect the issue may be related to the use of getBigDecimal since passing a scale is deprecated and the crash occurs when scaling the decimal.

https://github.com/aiven/aiven-kafka-connect-jdbc/blob/master/src/main/java/io/aiven/connect/jdbc/dialect/GenericDatabaseDialect.java#L1181

https://docs.oracle.com/javase/7/docs/api/java/sql/ResultSet.html#getBigDecimal(int,%20int)

We're running AIven JDBC Source connector version 6.6.0 on Kafka Connect 2.7.1 (Aiven hosted) and are querying Postgres 13.4 (Aiven hosted)

Beitragsleitfaden

Beitragsleitfaden öffnen

Bewertung

Dieses Issue wurde noch nicht bewertet.

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.