[incubator-seatunnel] branch dev updated: [bugfix] Check isOpen before closing (#2107)

[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/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 7ec0ada2b [bugfix] Check isOpen before closing (#2107)
7ec0ada2b is described below

commit 7ec0ada2b93d8fd5be103bb5b44acfc733798e0a
Author: ic4y <83933160+i...@users.noreply.github.com>
AuthorDate: Fri Jul 1 21:58:37 2022 +0800

    [bugfix] Check isOpen before closing (#2107)
---
 .../connectors/seatunnel/jdbc/sink/JdbcSinkAggregatedCommitter.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkAggregatedCommitter.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkAggregatedCommitter.java
index f0ee2671e..d142e95bb 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkAggregatedCommitter.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkAggregatedCommitter.java
@@ -83,7 +83,9 @@ public class JdbcSinkAggregatedCommitter
     public void close()
         throws IOException {
         try {
-            xaFacade.close();
+            if (xaFacade.isOpen()) {
+                xaFacade.close();
+            }
         } catch (Exception e) {
             ExceptionUtils.rethrowIOException(e);
         }