From 6cd6884958250a0b474a1d121067a8c47a2dd065 Mon Sep 17 00:00:00 2001
From: EchoLee5 <39044001+EchoLee5@users.noreply.github.com>
Date: Mon, 22 May 2023 17:05:53 +0800
Subject: [PATCH] [Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat
 database connection leak

---
 .../seatunnel/jdbc/internal/JdbcOutputFormat.java        | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormat.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormat.java
index d76dfdaf72c0..781f181923e7 100644
--- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormat.java
+++ b/seatunnel-connectors-v2/connector-jdbc/src/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);
                 }
             }