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