hi everyone,
I noticed jdbc sink doesn’t seem to s...
# troubleshootingd
DJ
01/26/2023, 12:21 AMhi everyone,
I noticed jdbc sink doesn’t seem to support writing array type for postgres? can anyone confirm?
DJ
01/26/2023, 12:21 AM Copy code
Caused by: java.lang.IllegalStateException: Writing ARRAY type is not yet supported in JDBC:PostgreSQL.
at org.apache.flink.connector.jdbc.internal.converter.PostgresRowConverter.lambda$createNullableExternalConverter$efaae646$1(PostgresRowConverter.java:69)
at org.apache.flink.connector.jdbc.converter.AbstractJdbcRowConverter.toExternal(AbstractJdbcRowConverter.java:87)
at org.apache.flink.connector.jdbc.internal.executor.TableSimpleStatementExecutor.addToBatch(TableSimpleStatementExecutor.java:58)
at org.apache.flink.connector.jdbc.internal.executor.TableSimpleStatementExecutor.addToBatch(TableSimpleStatementExecutor.java:35)
at org.apache.flink.connector.jdbc.internal.executor.TableBufferReducedStatementExecutor.executeBatch(TableBufferReducedStatementExecutor.java:95)
at org.apache.flink.connector.jdbc.internal.JdbcOutputFormat.attemptFlush(JdbcOutputFormat.java:246)
at org.apache.flink.connector.jdbc.internal.JdbcOutputFormat.flush(JdbcOutputFormat.java:216)
... 7 moreDJ
01/26/2023, 12:22 AMflink version 1.16
s
sap1ens
01/26/2023, 12:50 AMYep, I had to implement a patch for that.
m
Martijn Visser
01/26/2023, 8:24 AMI think that's related to https://issues.apache.org/jira/browse/FLINK-28596
d
DJ
01/26/2023, 2:28 PMthanks for the pointer.
3 Views