[Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat databas…

…e connection leak [Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat database connection leak
apache · May 26, 2023 · 9946b22 · 9946b22
1 parent 7a81fd3
commit 9946b22
Showing 1 changed file with 5 additions and 4 deletions.
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
@@ -219,10 +219,11 @@ public synchronized void close() {
                     flush();
                 } catch (Exception e) {
                     LOG.warn("Writing records to JDBC failed.", e);
-                    throw new JdbcConnectorException(
-                            CommonErrorCode.FLUSH_DATA_FAILED,
-                            "Writing records to JDBC failed.",
-                            e);
+                    flushException =
+                            new JdbcConnectorException(
+                                    CommonErrorCode.FLUSH_DATA_FAILED,
+                                    "Writing records to JDBC failed.",
+                                    e);
                 }
             }