commit ca6447fd1a1fccad4894cff16a94a35fa471c108
author zhangdonghao <39961809+hawk9821@users.noreply.github.com> Mon Oct 27 11:07:21 2025 +0800
committer GitHub <noreply@github.com> Mon Oct 27 11:07:21 2025 +0800
tree 8c723231947d84edac25b607c5fa29679343a38e
parent 4ceea92ab8a4867e1ade57cc705f2a8623d92b13

[fix][e2e]fix databend e2e (#9985)

seatunnel-e2e/seatunnel-connector-v2-e2e/connector-databend-e2e/src/test/java/org/apache/seatunnel/e2e/connector/databend/DatabendCDCSinkIT.java

diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-databend-e2e/src/test/java/org/apache/seatunnel/e2e/connector/databend/DatabendCDCSinkIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-databend-e2e/src/test/java/org/apache/seatunnel/e2e/connector/databend/DatabendCDCSinkIT.java
index c837dbe..5efb815 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-databend-e2e/src/test/java/org/apache/seatunnel/e2e/connector/databend/DatabendCDCSinkIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-databend-e2e/src/test/java/org/apache/seatunnel/e2e/connector/databend/DatabendCDCSinkIT.java
@@ -319,6 +319,11 @@
             }
         }
 
+        if (minioContainer != null) {
+            minioContainer.stop();
+            LOG.info("Minio container stopped");
+        }
+
         // Add a longer sleep to ensure all heartbeat threads are properly terminated
         Thread.sleep(10000);
 

seatunnel-e2e/seatunnel-connector-v2-e2e/connector-databend-e2e/src/test/java/org/apache/seatunnel/e2e/connector/databend/DatabendIT.java

diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-databend-e2e/src/test/java/org/apache/seatunnel/e2e/connector/databend/DatabendIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-databend-e2e/src/test/java/org/apache/seatunnel/e2e/connector/databend/DatabendIT.java
index 4f11394..b88e1ed 100644
--- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-databend-e2e/src/test/java/org/apache/seatunnel/e2e/connector/databend/DatabendIT.java
+++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-databend-e2e/src/test/java/org/apache/seatunnel/e2e/connector/databend/DatabendIT.java
@@ -457,6 +457,11 @@
             }
         }
 
+        if (minioContainer != null) {
+            minioContainer.stop();
+            LOG.info("Minio container stopped");
+        }
+
         Thread.sleep(5000);
 
         if (this.container != null) {