You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Timo Walther (Jira)" <ji...@apache.org> on 2021/01/22 09:57:00 UTC
[jira] [Closed] (FLINK-19771) NullPointerException when accessing
null array from postgres in JDBC Connector
[ https://issues.apache.org/jira/browse/FLINK-19771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timo Walther closed FLINK-19771.
--------------------------------
Fix Version/s: 1.12.2
1.11.4
1.13.0
Resolution: Fixed
Fixed in 1.13.0: 2bbac78b9eaa812b113cfc34f57c14ef3a3c35bc
Fixed in 1.12.2: d11137ea1f68a0480ada713e65065c092b281e1e
Fixed in 1.11.4: 428c67369bb1863e0d5e67b7b197fbd73f140e42
> NullPointerException when accessing null array from postgres in JDBC Connector
> ------------------------------------------------------------------------------
>
> Key: FLINK-19771
> URL: https://issues.apache.org/jira/browse/FLINK-19771
> Project: Flink
> Issue Type: Bug
> Components: Connectors / JDBC
> Affects Versions: 1.11.2
> Reporter: Dylan Forciea
> Assignee: Dylan Forciea
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.13.0, 1.11.4, 1.12.2
>
>
> When trying to utilize the JDBC Connector for Postgres, I tried to read in a text array. When a row that was null was attempted to be read in, the connector threw an exception and execution stopped. It appears looking at the source code that if the row is null that it will still attempt to grab the contents out: [https://github.com/apache/flink/blob/release-1.11.2/flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/PostgresRowConverter.java#L97]
> The stack trace is as follows:
> {code:java}
> [error] Caused by: java.io.IOException: Couldn't access resultSet
> [error] at org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat.nextRecord(JdbcRowDataInputFormat.java:266)
> [error] at org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat.nextRecord(JdbcRowDataInputFormat.java:57)
> [error] at org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:91)
> [error] at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
> [error] at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
> [error] at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:213)
> [error] Caused by: java.lang.NullPointerException
> [error] at org.apache.flink.connector.jdbc.internal.converter.PostgresRowConverter.lambda$createPostgresArrayConverter$c06ce9f4$2(PostgresRowConverter.java:97)
> [error] at org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.toInternal(AbstractJdbcRowConverter.java:79)
> [error] at org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat.nextRecord(JdbcRowDataInputFormat.java:259)
> [error] ... 5 more {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)