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

…e connection leak
apache · May 22, 2023 · 6cd6884 · 6cd6884
1 parent 31de52a
commit 6cd6884
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);
-                    flushException = 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);
                 }
             }