From 308cfe7bd0ecdbc9a54bd75f175aa7e987e3e405 Mon Sep 17 00:00:00 2001
From: zhangdonghao <hawk9821@qq.com>
Date: Mon, 27 Oct 2025 09:15:51 +0800
Subject: [PATCH] [fix][e2e]fix databend ci

---
 .../seatunnel/e2e/connector/databend/DatabendCDCSinkIT.java  | 5 +++++
 .../apache/seatunnel/e2e/connector/databend/DatabendIT.java  | 5 +++++
 2 files changed, 10 insertions(+)

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 c837dbeb611..5efb815f87d 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 @@ public void tearDown() throws Exception {
             }
         }
 
+        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);
 
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 4f1139465a6..b88e1edda86 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 @@ public void tearDown() throws Exception {
             }
         }
 
+        if (minioContainer != null) {
+            minioContainer.stop();
+            LOG.info("Minio container stopped");
+        }
+
         Thread.sleep(5000);
 
         if (this.container != null) {