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 a12e5b6c493 s
a12e5b6c493 is described below
commit a12e5b6c49354575d0bf1e75ecd8b8392f2f9b03
Author: Caideyipi <[email protected]>
AuthorDate: Tue Feb 10 10:23:48 2026 +0800
s
---
.../manual/AbstractPipeTableModelDualManualIT.java | 52 +++++++++++++++-------
.../tablemodel/manual/basic/IoTDBPipeAlterIT.java | 7 ---
.../manual/basic/IoTDBPipeDataSinkIT.java | 7 ---
.../manual/basic/IoTDBPipeIsolationIT.java | 7 ---
.../manual/basic/IoTDBPipeLifeCycleIT.java | 7 ---
.../tablemodel/manual/basic/IoTDBPipeMemoryIT.java | 26 ++++++-----
.../manual/basic/IoTDBPipePermissionIT.java | 21 ++++-----
.../manual/basic/IoTDBPipeProtocolIT.java | 26 ++++++++---
.../tablemodel/manual/basic/IoTDBPipeSourceIT.java | 22 ++++-----
.../manual/basic/IoTDBPipeSwitchStatusIT.java | 7 ---
.../tablemodel/manual/basic/IoTDBPipeSyntaxIT.java | 8 ----
.../manual/basic/IoTDBPipeWithLoadIT.java | 20 +++++----
.../manual/basic/IoTDBTablePatternFormatIT.java | 7 ---
.../manual/enhanced/IoTDBPipeAutoConflictIT.java | 20 +++++----
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 7 ---
.../manual/enhanced/IoTDBPipeClusterIT.java | 21 ++++-----
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 7 ---
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 7 ---
.../manual/enhanced/IoTDBPipeMetaIT.java | 7 ---
.../manual/enhanced/IoTDBPipeNullValueIT.java | 7 ---
.../enhanced/IoTDBPipeSinkCompressionIT.java | 28 +++++++-----
.../manual/enhanced/IoTDBPipeSinkParallelIT.java | 7 ---
.../IoTDBPipeTypeConversionISessionIT.java | 7 ---
.../manual/enhanced/IoTDBPipeTypeConversionIT.java | 7 ---
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 7 ---
.../auto/basic/IoTDBPipeSinkParallelIT.java | 7 ---
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 32 +++++++------
.../auto/basic/IoTDBPipeSwitchStatusIT.java | 7 ---
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 7 ---
.../auto/basic/IoTDBTreePatternFormatIT.java | 7 ---
30 files changed, 165 insertions(+), 244 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/AbstractPipeTableModelDualManualIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/AbstractPipeTableModelDualManualIT.java
index 3b3fae80902..f7670036446 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/AbstractPipeTableModelDualManualIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/AbstractPipeTableModelDualManualIT.java
@@ -20,29 +20,38 @@
package org.apache.iotdb.pipe.it.dual.tablemodel.manual;
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;
public abstract class AbstractPipeTableModelDualManualIT {
+ protected static ThreadLocal<BaseEnv> senderEnvContainer;
+ protected static ThreadLocal<BaseEnv> receiverEnvContainer;
+
protected BaseEnv senderEnv;
protected BaseEnv receiverEnv;
- @Before
- public void setUp() {
+ @BeforeClass
+ public static void setUp() {
MultiEnvFactory.createEnv(2);
- senderEnv = MultiEnvFactory.getEnv(0);
- receiverEnv = MultiEnvFactory.getEnv(1);
+ senderEnvContainer.set(MultiEnvFactory.getEnv(0));
+ receiverEnvContainer.set(MultiEnvFactory.getEnv(1));
setupConfig();
- senderEnv.initClusterEnvironment();
- receiverEnv.initClusterEnvironment();
+ senderEnvContainer.get().initClusterEnvironment();
+ receiverEnvContainer.get().initClusterEnvironment();
}
- protected void setupConfig() {
- senderEnv
+ protected static void setupConfig() {
+ senderEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -52,7 +61,8 @@ public abstract class AbstractPipeTableModelDualManualIT {
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
- receiverEnv
+ receiverEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -64,15 +74,27 @@ public abstract class AbstractPipeTableModelDualManualIT {
.setPipeAutoSplitFullEnabled(false);
// 10 min, assert that the operations will not time out
- senderEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
- receiverEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
+
senderEnvContainer.get().getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
+
receiverEnvContainer.get().getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
+
+
senderEnvContainer.get().getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
+ }
+
+ @AfterClass
+ public static void tearDown() {
+ senderEnvContainer.get().cleanClusterEnvironment();
+ receiverEnvContainer.get().cleanClusterEnvironment();
+ }
-
senderEnv.getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
+ @Before
+ public void setEnv() {
+ senderEnv = senderEnvContainer.get();
+ receiverEnv = receiverEnvContainer.get();
}
@After
- public final void tearDown() {
- senderEnv.cleanClusterEnvironment();
- receiverEnv.cleanClusterEnvironment();
+ public void cleanEnvironment() {
+ TestUtils.executeNonQueries(senderEnv, Arrays.asList("drop database
root.**"), null);
+ TestUtils.executeNonQueries(receiverEnv, Arrays.asList("drop database
root.**"), null);
}
}
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeAlterIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeAlterIT.java
index b2e1aaf539a..f41460a8e94 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeAlterIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeAlterIT.java
@@ -32,7 +32,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.TableModelUtils;
import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDualManualIT;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -49,12 +48,6 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeAlterIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testBasicAlterPipe() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeDataSinkIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeDataSinkIT.java
index 22ed58cb608..f1a4491711b 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeDataSinkIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeDataSinkIT.java
@@ -32,7 +32,6 @@ import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.tsfile.write.record.Tablet;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -53,12 +52,6 @@ import java.util.function.Consumer;
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeDataSinkIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testThriftConnectorWithRealtimeFirstDisabled() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeIsolationIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeIsolationIT.java
index 6924f17cedc..b0bdb5dd673 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeIsolationIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeIsolationIT.java
@@ -33,7 +33,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -49,12 +48,6 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeIsolationIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testWritePipeIsolation() throws Exception {
final String treePipeName = "treePipe";
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeLifeCycleIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeLifeCycleIT.java
index 3fd03bebd75..576c3cf8d5c 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeLifeCycleIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeLifeCycleIT.java
@@ -31,7 +31,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Ignore;
import org.junit.Test;
import org.junit.experimental.categories.Category;
@@ -51,12 +50,6 @@ import static
org.apache.iotdb.db.it.utils.TestUtils.executeNonQueryWithRetry;
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeLifeCycleIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testLifeCycleWithHistoryEnabled() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeMemoryIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeMemoryIT.java
index 757ddcda36a..b490475a096 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeMemoryIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeMemoryIT.java
@@ -22,6 +22,7 @@ package org.apache.iotdb.pipe.it.dual.tablemodel.manual.basic;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.commons.client.sync.SyncConfigNodeIServiceClient;
import org.apache.iotdb.confignode.rpc.thrift.TCreatePipeReq;
+import org.apache.iotdb.it.env.MultiEnvFactory;
import org.apache.iotdb.it.env.cluster.node.DataNodeWrapper;
import org.apache.iotdb.it.framework.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.MultiClusterIT2DualTableManualBasic;
@@ -29,7 +30,7 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -41,22 +42,27 @@ import java.util.Map;
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeMemoryIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
+ @BeforeClass
+ public static void setUp() {
+ MultiEnvFactory.createEnv(2);
+ senderEnvContainer.set(MultiEnvFactory.getEnv(0));
+ receiverEnvContainer.set(MultiEnvFactory.getEnv(1));
+ setupConfig();
+ senderEnvContainer.get().initClusterEnvironment();
+ receiverEnvContainer.get().initClusterEnvironment();
}
- @Override
- protected void setupConfig() {
- super.setupConfig();
- senderEnv
+ protected static void setupConfig() {
+ AbstractPipeTableModelDualManualIT.setupConfig();
+ senderEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setPipeMemoryManagementEnabled(true)
.setIsPipeEnableMemoryCheck(true)
.setDatanodeMemoryProportion("1000:1000:1000:1000:1:1000");
- receiverEnv
+ receiverEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setPipeMemoryManagementEnabled(true)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipePermissionIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipePermissionIT.java
index f233596fc60..692305e0e9a 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipePermissionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipePermissionIT.java
@@ -36,7 +36,7 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -54,14 +54,14 @@ import static org.junit.Assert.fail;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipePermissionIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
+ @BeforeClass
+ public static void setUp() {
MultiEnvFactory.createEnv(2);
- senderEnv = MultiEnvFactory.getEnv(0);
- receiverEnv = MultiEnvFactory.getEnv(1);
+ senderEnvContainer.set(MultiEnvFactory.getEnv(0));
+ receiverEnvContainer.set(MultiEnvFactory.getEnv(1));
- senderEnv
+ senderEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(false)
@@ -73,7 +73,8 @@ public class IoTDBPipePermissionIT extends
AbstractPipeTableModelDualManualIT {
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
- receiverEnv
+ receiverEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(false)
@@ -90,8 +91,8 @@ public class IoTDBPipePermissionIT extends
AbstractPipeTableModelDualManualIT {
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
- senderEnv.initClusterEnvironment();
- receiverEnv.initClusterEnvironment(3, 3);
+ senderEnvContainer.get().initClusterEnvironment();
+ receiverEnvContainer.get().initClusterEnvironment(3, 3);
}
@Test
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeProtocolIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeProtocolIT.java
index 3fce11bf51f..5bfb3f6614f 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeProtocolIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeProtocolIT.java
@@ -31,10 +31,13 @@ import org.apache.iotdb.it.framework.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.MultiClusterIT2DualTableManualBasic;
import org.apache.iotdb.pipe.it.dual.tablemodel.TableModelUtils;
import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDualManualIT;
+import
org.apache.iotdb.pipe.it.dual.treemodel.auto.AbstractPipeDualTreeModelAutoIT;
import org.apache.iotdb.rpc.TSStatusCode;
+import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -48,12 +51,21 @@ import java.util.function.Consumer;
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeProtocolIT extends AbstractPipeTableModelDualManualIT {
- @Override
+ @BeforeClass
+ public static void setUp() {
+ // Inner setup
+ }
+
@Before
- public void setUp() {
- MultiEnvFactory.createEnv(2);
- senderEnv = MultiEnvFactory.getEnv(0);
- receiverEnv = MultiEnvFactory.getEnv(1);
+ @Override
+ public void setEnv() {
+ // Inner set
+ }
+
+ @After
+ @Override
+ public final void cleanEnvironment() {
+ AbstractPipeDualTreeModelAutoIT.tearDown();
}
private void innerSetUp(
@@ -64,6 +76,10 @@ public class IoTDBPipeProtocolIT extends
AbstractPipeTableModelDualManualIT {
final int dataNodesNum,
int schemaRegionReplicationFactor,
int dataRegionReplicationFactor) {
+ MultiEnvFactory.createEnv(2);
+ senderEnv = MultiEnvFactory.getEnv(0);
+ receiverEnv = MultiEnvFactory.getEnv(1);
+
schemaRegionReplicationFactor = Math.min(schemaRegionReplicationFactor,
dataNodesNum);
dataRegionReplicationFactor = Math.min(dataRegionReplicationFactor,
dataNodesNum);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSourceIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSourceIT.java
index 022d71d5487..6739805dccb 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSourceIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSourceIT.java
@@ -34,7 +34,7 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Ignore;
import org.junit.Test;
import org.junit.experimental.categories.Category;
@@ -55,13 +55,14 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeSourceIT extends AbstractPipeTableModelDualManualIT {
- @Before
- public void setUp() {
+ @BeforeClass
+ public static void setUp() {
MultiEnvFactory.createEnv(2);
- senderEnv = MultiEnvFactory.getEnv(0);
- receiverEnv = MultiEnvFactory.getEnv(1);
+ senderEnvContainer.set(MultiEnvFactory.getEnv(0));
+ receiverEnvContainer.set(MultiEnvFactory.getEnv(1));
- senderEnv
+ senderEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -75,8 +76,9 @@ public class IoTDBPipeSourceIT extends
AbstractPipeTableModelDualManualIT {
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
-
senderEnv.getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
- receiverEnv
+
senderEnvContainer.get().getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
+ receiverEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -87,8 +89,8 @@ public class IoTDBPipeSourceIT extends
AbstractPipeTableModelDualManualIT {
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
- senderEnv.initClusterEnvironment();
- receiverEnv.initClusterEnvironment();
+ senderEnvContainer.get().initClusterEnvironment();
+ receiverEnvContainer.get().initClusterEnvironment();
}
@Test
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSwitchStatusIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSwitchStatusIT.java
index 53243cffaf3..3c4ede44bbb 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSwitchStatusIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSwitchStatusIT.java
@@ -34,7 +34,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -47,12 +46,6 @@ import java.util.Map;
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeSwitchStatusIT extends
AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testPipeSwitchStatus() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSyntaxIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSyntaxIT.java
index ec1afaa43ee..e52e417aef0 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSyntaxIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSyntaxIT.java
@@ -33,7 +33,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -51,13 +50,6 @@ import static org.junit.Assert.fail;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeSyntaxIT extends AbstractPipeTableModelDualManualIT {
-
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testValidPipeName() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeWithLoadIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeWithLoadIT.java
index 57b5846fc4b..e165937558b 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeWithLoadIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeWithLoadIT.java
@@ -34,7 +34,7 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Ignore;
import org.junit.Test;
import org.junit.experimental.categories.Category;
@@ -53,13 +53,14 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeWithLoadIT extends AbstractPipeTableModelDualManualIT {
- @Before
- public void setUp() {
+ @BeforeClass
+ public static void setUp() {
MultiEnvFactory.createEnv(2);
- senderEnv = MultiEnvFactory.getEnv(0);
- receiverEnv = MultiEnvFactory.getEnv(1);
+ senderEnvContainer.set(MultiEnvFactory.getEnv(0));
+ receiverEnvContainer.set(MultiEnvFactory.getEnv(1));
- senderEnv
+ senderEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -73,7 +74,8 @@ public class IoTDBPipeWithLoadIT extends
AbstractPipeTableModelDualManualIT {
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false)
.setEnforceStrongPassword(false);
- receiverEnv
+ receiverEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -84,8 +86,8 @@ public class IoTDBPipeWithLoadIT extends
AbstractPipeTableModelDualManualIT {
.setIsPipeEnableMemoryCheck(false)
.setEnforceStrongPassword(false);
- senderEnv.initClusterEnvironment();
- receiverEnv.initClusterEnvironment();
+ senderEnvContainer.get().initClusterEnvironment();
+ receiverEnvContainer.get().initClusterEnvironment();
}
@Ignore // not support
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBTablePatternFormatIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBTablePatternFormatIT.java
index e0945b120a0..c31e3037e34 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBTablePatternFormatIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBTablePatternFormatIT.java
@@ -31,7 +31,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -46,12 +45,6 @@ import java.util.function.Consumer;
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBTablePatternFormatIT extends
AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testTableNamePattern() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeAutoConflictIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeAutoConflictIT.java
index de0f0c460ee..a21f99601d3 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeAutoConflictIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeAutoConflictIT.java
@@ -34,7 +34,7 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -49,13 +49,14 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeAutoConflictIT extends
AbstractPipeTableModelDualManualIT {
- @Before
- public void setUp() {
+ @BeforeClass
+ public static void setUp() {
MultiEnvFactory.createEnv(2);
- senderEnv = MultiEnvFactory.getEnv(0);
- receiverEnv = MultiEnvFactory.getEnv(1);
+ senderEnvContainer.set(MultiEnvFactory.getEnv(0));
+ receiverEnvContainer.set(MultiEnvFactory.getEnv(1));
- senderEnv
+ senderEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -65,7 +66,8 @@ public class IoTDBPipeAutoConflictIT extends
AbstractPipeTableModelDualManualIT
.setDnConnectionTimeoutMs(600000)
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false);
- receiverEnv
+ receiverEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -76,8 +78,8 @@ public class IoTDBPipeAutoConflictIT extends
AbstractPipeTableModelDualManualIT
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false);
- senderEnv.initClusterEnvironment();
- receiverEnv.initClusterEnvironment();
+ senderEnvContainer.get().initClusterEnvironment();
+ receiverEnvContainer.get().initClusterEnvironment();
}
@Test
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeAutoDropIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeAutoDropIT.java
index 6ab974c2f1e..9ec5c007fcb 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeAutoDropIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeAutoDropIT.java
@@ -33,7 +33,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -54,12 +53,6 @@ import static org.awaitility.Awaitility.await;
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeAutoDropIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testAutoDropInHistoricalTransfer() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeClusterIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeClusterIT.java
index 4350d4072bb..b746d088698 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeClusterIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeClusterIT.java
@@ -42,7 +42,7 @@ import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.thrift.TException;
import org.junit.Assert;
-import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -62,14 +62,14 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeClusterIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
+ @BeforeClass
+ public static void setUp() {
MultiEnvFactory.createEnv(2);
- senderEnv = MultiEnvFactory.getEnv(0);
- receiverEnv = MultiEnvFactory.getEnv(1);
+ senderEnvContainer.set(MultiEnvFactory.getEnv(0));
+ receiverEnvContainer.set(MultiEnvFactory.getEnv(1));
- senderEnv
+ senderEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -80,7 +80,8 @@ public class IoTDBPipeClusterIT extends
AbstractPipeTableModelDualManualIT {
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false);
- receiverEnv
+ receiverEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -93,8 +94,8 @@ public class IoTDBPipeClusterIT extends
AbstractPipeTableModelDualManualIT {
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false);
- senderEnv.initClusterEnvironment(3, 3, 180);
- receiverEnv.initClusterEnvironment(3, 3, 180);
+ senderEnvContainer.get().initClusterEnvironment(3, 3, 180);
+ receiverEnvContainer.get().initClusterEnvironment(3, 3, 180);
}
@Test
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java
index 4d5f350a7c7..c8b51eea67f 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java
@@ -34,7 +34,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -53,12 +52,6 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeDoubleLivingIT extends
AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testDoubleLivingInvalidParameter() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java
index 6c22d418226..5a7a96a6b78 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java
@@ -32,7 +32,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -47,12 +46,6 @@ import java.util.Map;
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeIdempotentIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testCreateTableIdempotent() throws Exception {
testTableConfigIdempotent(Collections.emptyList(), "create table test()");
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeMetaIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeMetaIT.java
index 936ca1f5097..cc2387154b8 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeMetaIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeMetaIT.java
@@ -33,7 +33,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -54,12 +53,6 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeMetaIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testTableSync() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeNullValueIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeNullValueIT.java
index 9d635cd8095..b1743b8daeb 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeNullValueIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeNullValueIT.java
@@ -31,7 +31,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -44,12 +43,6 @@ import java.util.function.Consumer;
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeNullValueIT extends AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
private enum InsertType {
SESSION_INSERT_RECORD,
SESSION_INSERT_TABLET,
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkCompressionIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkCompressionIT.java
index 547db349e2f..4fdbfb01d14 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkCompressionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkCompressionIT.java
@@ -38,7 +38,7 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -58,16 +58,15 @@ import static org.junit.Assert.fail;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeSinkCompressionIT extends
AbstractPipeTableModelDualManualIT {
-
- @Override
- @Before
- public void setUp() {
+ @BeforeClass
+ public static void setUp() {
// Override to enable air-gap
MultiEnvFactory.createEnv(2);
- senderEnv = MultiEnvFactory.getEnv(0);
- receiverEnv = MultiEnvFactory.getEnv(1);
+ senderEnvContainer.set(MultiEnvFactory.getEnv(0));
+ receiverEnvContainer.set(MultiEnvFactory.getEnv(1));
- senderEnv
+ senderEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -77,8 +76,13 @@ public class IoTDBPipeSinkCompressionIT extends
AbstractPipeTableModelDualManual
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
-
senderEnv.getConfig().getDataNodeConfig().setDataNodeMemoryProportion("3:3:1:1:3:1");
- receiverEnv
+ senderEnvContainer
+ .get()
+ .getConfig()
+ .getDataNodeConfig()
+ .setDataNodeMemoryProportion("3:3:1:1:3:1");
+ receiverEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -90,8 +94,8 @@ public class IoTDBPipeSinkCompressionIT extends
AbstractPipeTableModelDualManual
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
- senderEnv.initClusterEnvironment();
- receiverEnv.initClusterEnvironment();
+ senderEnvContainer.get().initClusterEnvironment();
+ receiverEnvContainer.get().initClusterEnvironment();
}
@Test
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkParallelIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkParallelIT.java
index 85f3b93aa76..4e3f1c09cc5 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkParallelIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeSinkParallelIT.java
@@ -31,7 +31,6 @@ import
org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDua
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -47,12 +46,6 @@ import java.util.function.Consumer;
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeSinkParallelIT extends
AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testIoTConnectorParallel() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeTypeConversionISessionIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeTypeConversionISessionIT.java
index 46bc9e71607..8f29e9d094c 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeTypeConversionISessionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeTypeConversionISessionIT.java
@@ -42,7 +42,6 @@ import org.apache.tsfile.utils.Pair;
import org.apache.tsfile.write.record.Tablet;
import org.apache.tsfile.write.schema.IMeasurementSchema;
import org.apache.tsfile.write.schema.MeasurementSchema;
-import org.junit.Before;
import org.junit.Ignore;
import org.junit.Test;
import org.junit.experimental.categories.Category;
@@ -67,12 +66,6 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeTypeConversionISessionIT extends
AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
private static final int generateDataSize = 1000;
@Test
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeTypeConversionIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeTypeConversionIT.java
index 68adc122613..86860160b36 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeTypeConversionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeTypeConversionIT.java
@@ -32,7 +32,6 @@ import org.apache.tsfile.utils.Binary;
import org.apache.tsfile.utils.BytesUtils;
import org.apache.tsfile.utils.DateUtils;
import org.apache.tsfile.utils.Pair;
-import org.junit.Before;
import org.junit.Ignore;
import org.junit.Test;
import org.junit.experimental.categories.Category;
@@ -56,12 +55,6 @@ import java.util.function.Consumer;
"Currently this may lose some data because tsFile conversion is banned,
and historical transferred is not opened if history.enable = false")
public class IoTDBPipeTypeConversionIT extends
AbstractPipeTableModelDualManualIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
private static final int generateDataSize = 100;
// Test for converting BOOLEAN to OtherType
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeLifeCycleIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeLifeCycleIT.java
index 226c9344e7a..cad16a79181 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeLifeCycleIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeLifeCycleIT.java
@@ -31,7 +31,6 @@ import
org.apache.iotdb.pipe.it.dual.treemodel.auto.AbstractPipeDualTreeModelAut
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -57,12 +56,6 @@ import static
org.apache.iotdb.db.it.utils.TestUtils.grantUserSystemPrivileges;
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBPipeLifeCycleIT extends AbstractPipeDualTreeModelAutoIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testLifeCycleWithHistoryEnabled() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSinkParallelIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSinkParallelIT.java
index c21e6456ef1..2a92f484ed0 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSinkParallelIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSinkParallelIT.java
@@ -30,7 +30,6 @@ import
org.apache.iotdb.pipe.it.dual.treemodel.auto.AbstractPipeDualTreeModelAut
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -45,12 +44,6 @@ import java.util.Set;
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBPipeSinkParallelIT extends AbstractPipeDualTreeModelAutoIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testIoTConnectorParallel() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSourceIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSourceIT.java
index a45115f5a49..a95e9099178 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSourceIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSourceIT.java
@@ -36,7 +36,7 @@ import
org.apache.iotdb.pipe.it.dual.treemodel.auto.AbstractPipeDualTreeModelAut
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -57,13 +57,14 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBPipeSourceIT extends AbstractPipeDualTreeModelAutoIT {
- @Before
- public void setUp() {
+ @BeforeClass
+ public static void setUp() {
MultiEnvFactory.createEnv(2);
- senderEnv = MultiEnvFactory.getEnv(0);
- receiverEnv = MultiEnvFactory.getEnv(1);
+ senderEnvContainer.set(MultiEnvFactory.getEnv(0));
+ receiverEnvContainer.set(MultiEnvFactory.getEnv(1));
- senderEnv
+ senderEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -76,8 +77,9 @@ public class IoTDBPipeSourceIT extends
AbstractPipeDualTreeModelAutoIT {
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
-
senderEnv.getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
- receiverEnv
+
senderEnvContainer.get().getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
+ receiverEnvContainer
+ .get()
.getConfig()
.getCommonConfig()
.setAutoCreateSchemaEnabled(true)
@@ -86,14 +88,18 @@ public class IoTDBPipeSourceIT extends
AbstractPipeDualTreeModelAutoIT {
.setPipeMemoryManagementEnabled(false)
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
-
receiverEnv.getConfig().getConfigNodeConfig().setLeaderDistributionPolicy("HASH");
+ receiverEnvContainer
+ .get()
+ .getConfig()
+ .getConfigNodeConfig()
+ .setLeaderDistributionPolicy("HASH");
// 10 min, assert that the operations will not time out
- senderEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
- receiverEnv.getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
+
senderEnvContainer.get().getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
+
receiverEnvContainer.get().getConfig().getCommonConfig().setDnConnectionTimeoutMs(600000);
- senderEnv.initClusterEnvironment();
- receiverEnv.initClusterEnvironment();
+ senderEnvContainer.get().initClusterEnvironment();
+ receiverEnvContainer.get().initClusterEnvironment();
}
@Test
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSwitchStatusIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSwitchStatusIT.java
index ce197b94356..291dbf0cb01 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSwitchStatusIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSwitchStatusIT.java
@@ -34,7 +34,6 @@ import
org.apache.iotdb.pipe.it.dual.treemodel.auto.AbstractPipeDualTreeModelAut
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -47,12 +46,6 @@ import java.util.Map;
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBPipeSwitchStatusIT extends AbstractPipeDualTreeModelAutoIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testPipeSwitchStatus() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSyntaxIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSyntaxIT.java
index 6ae8d56bfaa..1207c6e30a1 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSyntaxIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeSyntaxIT.java
@@ -33,7 +33,6 @@ import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.tsfile.external.commons.lang3.SystemUtils;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -54,12 +53,6 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBPipeSyntaxIT extends AbstractPipeDualTreeModelAutoIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testValidPipeName() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBTreePatternFormatIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBTreePatternFormatIT.java
index fc5d483ea5c..e65865fb90f 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBTreePatternFormatIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBTreePatternFormatIT.java
@@ -30,7 +30,6 @@ import
org.apache.iotdb.pipe.it.dual.treemodel.auto.AbstractPipeDualTreeModelAut
import org.apache.iotdb.rpc.TSStatusCode;
import org.junit.Assert;
-import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -46,12 +45,6 @@ import java.util.Set;
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBTreePatternFormatIT extends AbstractPipeDualTreeModelAutoIT {
- @Override
- @Before
- public void setUp() {
- super.setUp();
- }
-
@Test
public void testPrefixPattern() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
