[seatunnel] branch dev updated: [Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat database connection leak (#4802)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 4cc10e83e7 [Hotfix][Connector][Jdbc] Fix the problem of 
JdbcOutputFormat database connection leak (#4802)
4cc10e83e7 is described below

commit 4cc10e83e774ff14e061b669aee888d20b021b3f
Author: EchoLee5 <39044001+echol...@users.noreply.github.com>
AuthorDate: Fri Jul 21 14:24:26 2023 +0800

    [Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat database 
connection leak (#4802)
    
    [Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat database 
connection leak
---
 .../connectors/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 ee3c4a7a68..d47814f153 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 class JdbcOutputFormat<I, E extends 
JdbcBatchStatementExecutor<I>> implem
                     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);
                 }
             }