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

Unable to process numeric types

未关闭
#100 0 条评论 0 个 reaction 已指派 0 人 在 GitHub 查看
主要语言
Java
星标
113
派生
62
平均合并
4 小时 12 分钟
30 天内合并 PR
1

描述

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)

贡献指南

打开贡献指南

评估

这个 Issue 还没有评估数据。

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。