This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 92bb0a19f0a Pipe IT: explicitly declare `setUp` method for test class
to avoid `UNKNOWN-IT` test class name (#14874)
92bb0a19f0a is described below
commit 92bb0a19f0acba8de3d30606ddf7a0babef897e4
Author: VGalaxies <[email protected]>
AuthorDate: Tue Feb 18 10:42:34 2025 +0800
Pipe IT: explicitly declare `setUp` method for test class to avoid
`UNKNOWN-IT` test class name (#14874)
---
.../pipe/it/dual/tablemodel/manual/basic/IoTDBPipeAlterIT.java | 7 +++++++
.../pipe/it/dual/tablemodel/manual/basic/IoTDBPipeDataSinkIT.java | 7 +++++++
.../it/dual/tablemodel/manual/basic/IoTDBPipeIsolationIT.java | 7 +++++++
.../it/dual/tablemodel/manual/basic/IoTDBPipeLifeCycleIT.java | 8 ++++++++
.../pipe/it/dual/tablemodel/manual/basic/IoTDBPipeProtocolIT.java | 1 +
.../it/dual/tablemodel/manual/basic/IoTDBPipeSwitchStatusIT.java | 8 ++++++++
.../pipe/it/dual/tablemodel/manual/basic/IoTDBPipeSyntaxIT.java | 8 ++++++++
.../dual/tablemodel/manual/basic/IoTDBTablePatternFormatIT.java | 7 +++++++
.../dual/tablemodel/manual/enhanced/IoTDBPipeAutoConflictIT.java | 1 +
.../it/dual/tablemodel/manual/enhanced/IoTDBPipeAutoDropIT.java | 7 +++++++
.../tablemodel/manual/enhanced/IoTDBPipeConnectorParallelIT.java | 8 ++++++++
.../dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java | 7 +++++++
.../it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java | 8 ++++++++
.../pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeMetaIT.java | 8 ++++++++
.../it/dual/tablemodel/manual/enhanced/IoTDBPipeNullValueIT.java | 7 +++++++
.../manual/enhanced/IoTDBPipeTypeConversionISessionIT.java | 8 ++++++++
.../tablemodel/manual/enhanced/IoTDBPipeTypeConversionIT.java | 7 +++++++
.../iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAlterIT.java | 7 +++++++
.../dual/treemodel/auto/basic/IoTDBPipeConnectorParallelIT.java | 8 ++++++++
.../pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 8 ++++++++
.../pipe/it/dual/treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 8 ++++++++
.../pipe/it/dual/treemodel/auto/basic/IoTDBPipeProcessorIT.java | 1 +
.../pipe/it/dual/treemodel/auto/basic/IoTDBPipeProtocolIT.java | 1 +
.../it/dual/treemodel/auto/basic/IoTDBPipeSwitchStatusIT.java | 8 ++++++++
.../pipe/it/dual/treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 8 ++++++++
.../it/dual/treemodel/auto/basic/IoTDBTreePatternFormatIT.java | 8 ++++++++
.../it/dual/treemodel/auto/enhanced/IoTDBPipeAutoConflictIT.java | 1 +
.../pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java | 7 +++++++
.../treemodel/auto/enhanced/IoTDBPipeConditionalOperationsIT.java | 7 +++++++
.../it/dual/treemodel/auto/enhanced/IoTDBPipeIdempotentIT.java | 1 +
.../pipe/it/dual/treemodel/auto/enhanced/PipeNowFunctionIT.java | 7 +++++++
31 files changed, 194 insertions(+)
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 93bb1424c2b..72806ccbb2a 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
@@ -31,6 +31,7 @@ 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;
@@ -47,6 +48,12 @@ 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 7c98f652f73..7b60770cbfd 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,6 +32,7 @@ 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;
@@ -52,6 +53,12 @@ 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 b0bdb5dd673..6924f17cedc 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,6 +33,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -48,6 +49,12 @@ 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 ff03b5dbc69..ff84de1f99c 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
@@ -33,6 +33,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.Ignore;
import org.junit.Test;
import org.junit.experimental.categories.Category;
@@ -56,6 +57,13 @@ import static
org.apache.iotdb.db.it.utils.TestUtils.grantUserSystemPrivileges;
@RunWith(IoTDBTestRunner.class)
@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/IoTDBPipeProtocolIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeProtocolIT.java
index 3fe82b52b97..bcc2f00734d 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
@@ -47,6 +47,7 @@ import java.util.function.Consumer;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTableManualBasic.class})
public class IoTDBPipeProtocolIT extends AbstractPipeTableModelDualManualIT {
+
@Override
@Before
public void setUp() {
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 b6b29deaac2..de90b7144f2 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
@@ -33,6 +33,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -44,6 +45,13 @@ import java.util.Map;
@RunWith(IoTDBTestRunner.class)
@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 bc5233f1dd8..af0c14da887 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
@@ -32,6 +32,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -49,6 +50,13 @@ 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/IoTDBTablePatternFormatIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBTablePatternFormatIT.java
index b3bd7cd8586..0665cf189c9 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,6 +31,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -45,6 +46,12 @@ 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 fc29e3e12a7..75c3da9cd3e 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
@@ -48,6 +48,7 @@ import static org.junit.Assert.fail;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeAutoConflictIT extends
AbstractPipeTableModelDualManualIT {
+
@Before
public void setUp() {
MultiEnvFactory.createEnv(2);
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 cbf2c307397..e34228a2665 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,6 +33,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -53,6 +54,12 @@ 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/IoTDBPipeConnectorParallelIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeConnectorParallelIT.java
index 7c2c56a0fd7..bf04ec1e77f 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeConnectorParallelIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeConnectorParallelIT.java
@@ -31,6 +31,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -45,6 +46,13 @@ import java.util.function.Consumer;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTableManualEnhanced.class})
public class IoTDBPipeConnectorParallelIT 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/IoTDBPipeDoubleLivingIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeDoubleLivingIT.java
index 55c2aae1290..70c7e1605de 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
@@ -33,6 +33,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -51,6 +52,12 @@ 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 c80a67c4d4f..1f507049130 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,6 +32,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -45,6 +46,13 @@ import java.util.Map;
@RunWith(IoTDBTestRunner.class)
@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 4e33f8369d6..c9f53364c1b 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
@@ -32,6 +32,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -45,6 +46,13 @@ import java.util.Map;
@RunWith(IoTDBTestRunner.class)
@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 de59d7ef8a6..877fd9fc819 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,6 +31,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -43,6 +44,12 @@ 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/IoTDBPipeTypeConversionISessionIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeTypeConversionISessionIT.java
index 606fba4d17e..3f48b10ca17 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,6 +42,7 @@ import org.apache.tsfile.write.record.Tablet;
import org.apache.tsfile.write.record.Tablet.ColumnCategory;
import org.apache.tsfile.write.schema.IMeasurementSchema;
import org.apache.tsfile.write.schema.MeasurementSchema;
+import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -64,6 +65,13 @@ import static org.junit.Assert.fail;
@RunWith(IoTDBTestRunner.class)
@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 d9597574c7b..bfc47abb158 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,6 +32,7 @@ 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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -52,6 +53,12 @@ import java.util.function.Consumer;
@Category({MultiClusterIT2DualTableManualEnhanced.class})
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/IoTDBPipeAlterIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAlterIT.java
index b1c8c4cf995..564bc34aee5 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAlterIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeAlterIT.java
@@ -29,6 +29,7 @@ import
org.apache.iotdb.itbase.category.MultiClusterIT2DualTreeAutoBasic;
import
org.apache.iotdb.pipe.it.dual.treemodel.auto.AbstractPipeDualTreeModelAutoIT;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -48,6 +49,12 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBPipeAlterIT extends AbstractPipeDualTreeModelAutoIT {
+ @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/treemodel/auto/basic/IoTDBPipeConnectorParallelIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeConnectorParallelIT.java
index 8857f194217..45169c41630 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeConnectorParallelIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeConnectorParallelIT.java
@@ -30,6 +30,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -43,6 +44,13 @@ import java.util.Set;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBPipeConnectorParallelIT 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/IoTDBPipeDataSinkIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
index 8855bf4e25f..1dd102f0e59 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java
@@ -30,6 +30,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -43,6 +44,13 @@ import java.util.Map;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBPipeDataSinkIT extends AbstractPipeDualTreeModelAutoIT {
+
+ @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/treemodel/auto/basic/IoTDBPipeLifeCycleIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeLifeCycleIT.java
index 9e03b3d8032..9ee9df2d571 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,6 +31,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -54,6 +55,13 @@ import static
org.apache.iotdb.db.it.utils.TestUtils.grantUserSystemPrivileges;
@RunWith(IoTDBTestRunner.class)
@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/IoTDBPipeProcessorIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeProcessorIT.java
index 4a17939065f..0face7e1dd1 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeProcessorIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeProcessorIT.java
@@ -46,6 +46,7 @@ import java.util.Set;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBPipeProcessorIT extends AbstractPipeDualTreeModelAutoIT {
+
@Before
public void setUp() {
MultiEnvFactory.createEnv(2);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeProtocolIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeProtocolIT.java
index 6035ed9c16a..b286cc61365 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeProtocolIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/basic/IoTDBPipeProtocolIT.java
@@ -47,6 +47,7 @@ import java.util.Map;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTreeAutoBasic.class})
public class IoTDBPipeProtocolIT extends AbstractPipeDualTreeModelAutoIT {
+
@Override
@Before
public void setUp() {
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 ee70f1a3a3b..d015e4641b7 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
@@ -33,6 +33,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -44,6 +45,13 @@ import java.util.Map;
@RunWith(IoTDBTestRunner.class)
@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 a0450942d47..8d5d7097810 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
@@ -31,6 +31,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -48,6 +49,13 @@ import static org.junit.Assert.fail;
@RunWith(IoTDBTestRunner.class)
@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 28fa6621312..608aae2b4ae 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,6 +30,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -43,6 +44,13 @@ import java.util.Set;
@RunWith(IoTDBTestRunner.class)
@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);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoConflictIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoConflictIT.java
index 65eb0d1ea14..34b42c35c14 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoConflictIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoConflictIT.java
@@ -47,6 +47,7 @@ import java.util.Set;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTreeAutoEnhanced.class})
public class IoTDBPipeAutoConflictIT extends AbstractPipeDualTreeModelAutoIT {
+
@Before
public void setUp() {
MultiEnvFactory.createEnv(2);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java
index f1c3672e14a..493a991ae1b 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeAutoDropIT.java
@@ -32,6 +32,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -51,6 +52,12 @@ import static org.awaitility.Awaitility.await;
@Category({MultiClusterIT2DualTreeAutoEnhanced.class})
public class IoTDBPipeAutoDropIT extends AbstractPipeDualTreeModelAutoIT {
+ @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/treemodel/auto/enhanced/IoTDBPipeConditionalOperationsIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeConditionalOperationsIT.java
index 36a12d5bcd6..3e75838dd3d 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeConditionalOperationsIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeConditionalOperationsIT.java
@@ -28,6 +28,7 @@ import
org.apache.iotdb.itbase.category.MultiClusterIT2DualTreeAutoEnhanced;
import
org.apache.iotdb.pipe.it.dual.treemodel.auto.AbstractPipeDualTreeModelAutoIT;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -43,6 +44,12 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTreeAutoEnhanced.class})
public class IoTDBPipeConditionalOperationsIT extends
AbstractPipeDualTreeModelAutoIT {
+ @Override
+ @Before
+ public void setUp() {
+ super.setUp();
+ }
+
@Test
public void testBasicCreatePipeIfNotExists() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeIdempotentIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeIdempotentIT.java
index e741ab82f6d..14ba0bfbeff 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeIdempotentIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/IoTDBPipeIdempotentIT.java
@@ -47,6 +47,7 @@ import java.util.Set;
@RunWith(IoTDBTestRunner.class)
@Category({MultiClusterIT2DualTreeAutoEnhanced.class})
public class IoTDBPipeIdempotentIT extends AbstractPipeDualTreeModelAutoIT {
+
@Override
@Before
public void setUp() {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/PipeNowFunctionIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/PipeNowFunctionIT.java
index 471a1e81594..09845735dc1 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/PipeNowFunctionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/enhanced/PipeNowFunctionIT.java
@@ -33,6 +33,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.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -50,6 +51,12 @@ import static org.junit.Assert.fail;
@Category({MultiClusterIT2DualTreeAutoEnhanced.class})
public class PipeNowFunctionIT extends AbstractPipeDualTreeModelAutoIT {
+ @Override
+ @Before
+ public void setUp() {
+ super.setUp();
+ }
+
@Test
public void testPipeNowFunction() throws Exception {
final DataNodeWrapper receiverDataNode = receiverEnv.getDataNodeWrapper(0);
