[Hotfix][Connector][Jdbc] Fix reconnect throw close statement exception

apache · May 22, 2023 · c9cbecc · c9cbecc
1 parent 7d61ae9
commit c9cbecc
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/...c/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormat.java b/...c/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormat.java
@@ -239,7 +239,14 @@ public synchronized void close() {
     }
 
     public void updateExecutor(boolean reconnect) throws SQLException, ClassNotFoundException {
-        jdbcStatementExecutor.closeStatements();
+        try {
+            jdbcStatementExecutor.closeStatements();
+        } catch (SQLException e) {
+            if (!reconnect) {
+                throw e;
+            }
+            LOG.info("Close JDBC statement failed on reconnect.", e);
+        }
         jdbcStatementExecutor.prepareStatements(
                 reconnect
                         ? connectionProvider.reestablishConnection()