[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

["Danny Cranmer (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Danny Cranmer updated FLINK-30371:
----------------------------------
    Fix Version/s: jdbc-3.2.0
                       (was: jdbc-3.1.0)

> JdbcOutputFormat is at risk of database connection leaks
> --------------------------------------------------------
>
>                 Key: FLINK-30371
>                 URL: https://issues.apache.org/jira/browse/FLINK-30371
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / JDBC
>    Affects Versions: 1.16.0, 1.16.1, jdbc-3.0.0
>            Reporter: Echo Lee
>            Assignee: Echo Lee
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: jdbc-3.2.0
>
>
> When writing to the target table fails for some reason, for example, the target table does not exist.
> The internal call sequence of JdbcOutputFormat is:
> JdbcOutputFormat#flush(throws IOException) --> JdbcOutputFormat#close --> JdbcOutputFormat#flush(throws RuntimeException).
> Will not call the close method of the database connection, when the restart strategy is fixeddelay, maxNumberRestartAttempts is Integer.MAX, this will cause the number of database connections to continue to rise and reach the limit.
>  
> {code:java}
> 2022-12-07 10:49:32,050 ERROR org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat [] - JDBC executeBatch error, retry times = 3
> java.sql.BatchUpdateException: ORA-00942: table or view does not exist{code}
> {code:java}
> Caused by: java.sql.SQLException: Listener refused the connection with the following error:
> ORA-12519, TNS:no appropriate service handler found {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)