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);
+ }
}