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

justinchen pushed a commit to branch restart-check-pw
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/restart-check-pw by this push:
     new 71524e05d32 working
71524e05d32 is described below

commit 71524e05d327a7d76ef6d978d850a9bd845f597e
Author: Caideyipi <[email protected]>
AuthorDate: Mon Feb 9 18:21:47 2026 +0800

    working
---
 .../pipe/it/triple/AbstractPipeTripleManualIT.java | 28 +++++++++++++++-------
 1 file changed, 20 insertions(+), 8 deletions(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/triple/AbstractPipeTripleManualIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/triple/AbstractPipeTripleManualIT.java
index f4e63e1d2f8..917242979b7 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/triple/AbstractPipeTripleManualIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/triple/AbstractPipeTripleManualIT.java
@@ -20,20 +20,25 @@
 package org.apache.iotdb.pipe.it.triple;
 
 import org.apache.iotdb.consensus.ConsensusFactory;
+import org.apache.iotdb.db.it.utils.TestUtils;
 import org.apache.iotdb.it.env.MultiEnvFactory;
 import org.apache.iotdb.itbase.env.BaseEnv;
 
 import org.junit.After;
+import org.junit.AfterClass;
 import org.junit.Before;
+import org.junit.BeforeClass;
+
+import java.util.Arrays;
 
 abstract class AbstractPipeTripleManualIT {
 
-  protected BaseEnv env1;
-  protected BaseEnv env2;
-  protected BaseEnv env3;
+  protected static BaseEnv env1;
+  protected static BaseEnv env2;
+  protected static BaseEnv env3;
 
-  @Before
-  public void setUp() {
+  @BeforeClass
+  public static void setUp() {
     MultiEnvFactory.createEnv(3);
     env1 = MultiEnvFactory.getEnv(0);
     env2 = MultiEnvFactory.getEnv(1);
@@ -44,7 +49,7 @@ abstract class AbstractPipeTripleManualIT {
     env3.initClusterEnvironment(1, 1);
   }
 
-  protected void setupConfig() {
+  protected static void setupConfig() {
     env1.getConfig()
         .getCommonConfig()
         .setAutoCreateSchemaEnabled(false)
@@ -79,10 +84,17 @@ abstract class AbstractPipeTripleManualIT {
     env3.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
   }
 
-  @After
-  public final void tearDown() {
+  @AfterClass
+  public static void tearDown() {
     env1.cleanClusterEnvironment();
     env2.cleanClusterEnvironment();
     env3.cleanClusterEnvironment();
   }
+
+  @After
+  public final void cleanEnvironments() {
+    TestUtils.executeNonQueries(env1, Arrays.asList("drop database root.**"), 
null);
+    TestUtils.executeNonQueries(env2, Arrays.asList("drop database root.**"), 
null);
+    TestUtils.executeNonQueries(env3, Arrays.asList("drop database root.**"), 
null);
+  }
 }

Reply via email to