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

gaojun2048 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 b38826e7a [bugfix][connector-v2] closed gp container after use (#3319)
b38826e7a is described below

commit b38826e7a2813b97bb0dc0f67cee7a66a6a4efe1
Author: ic4y <[email protected]>
AuthorDate: Mon Nov 7 16:12:22 2022 +0800

    [bugfix][connector-v2] closed gp container after use (#3319)
---
 .../java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcGreenplumIT.java   | 3 +++
 .../java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcGreenplumIT.java   | 3 +++
 2 files changed, 6 insertions(+)

diff --git 
a/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcGreenplumIT.java
 
b/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcGreenplumIT.java
index fb46e52d4..d779d1ffa 100644
--- 
a/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcGreenplumIT.java
+++ 
b/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/jdbc/JdbcGreenplumIT.java
@@ -158,6 +158,9 @@ public class JdbcGreenplumIT extends FlinkContainer {
         if (jdbcConnection != null) {
             jdbcConnection.close();
         }
+        if (greenplumServer != null) {
+            greenplumServer.stop();
+        }
     }
 
     @Override
diff --git 
a/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcGreenplumIT.java
 
b/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcGreenplumIT.java
index 7ed810ee1..006079733 100644
--- 
a/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcGreenplumIT.java
+++ 
b/seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/jdbc/JdbcGreenplumIT.java
@@ -159,6 +159,9 @@ public class JdbcGreenplumIT extends SparkContainer {
         if (jdbcConnection != null) {
             jdbcConnection.close();
         }
+        if (greenplumServer != null) {
+            greenplumServer.stop();
+        }
     }
 
     @Override

Reply via email to