This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch run-ci-mod
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/run-ci-mod by this push:
new bfd8481bea8 fix
bfd8481bea8 is described below
commit bfd8481bea88419236a76f5b414ad0de0c8e72f9
Author: Caideyipi <[email protected]>
AuthorDate: Thu Mar 26 10:43:17 2026 +0800
fix
---
.../it/dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java | 8 ++++++--
.../pipe/it/dual/treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 3 ++-
2 files changed, 8 insertions(+), 3 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java
index a7fae02f6d1..e0ac22a80e1 100644
---
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java
@@ -45,8 +45,8 @@ public abstract class AbstractPipeDualTreeModelAutoIT {
senderEnv = MultiEnvFactory.getEnv(0);
receiverEnv = MultiEnvFactory.getEnv(1);
setupConfig();
- senderEnv.initClusterEnvironment();
- receiverEnv.initClusterEnvironment();
+ senderEnv.initClusterEnvironment(1, 1);
+ receiverEnv.initClusterEnvironment(1, 1);
}
protected void setupConfig() {
@@ -58,6 +58,8 @@ public abstract class AbstractPipeDualTreeModelAutoIT {
.setSchemaRegionConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
.setEnforceStrongPassword(false)
.setPipeMemoryManagementEnabled(false)
+ .setDataReplicationFactor(1)
+ .setSchemaReplicationFactor(1)
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
senderEnv.getConfig().getDataNodeConfig().setDataNodeMemoryProportion("3:3:1:1:3:1");
@@ -68,6 +70,8 @@ public abstract class AbstractPipeDualTreeModelAutoIT {
.setConfigNodeConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
.setSchemaRegionConsensusProtocolClass(ConsensusFactory.RATIS_CONSENSUS)
.setPipeMemoryManagementEnabled(false)
+ .setDataReplicationFactor(1)
+ .setSchemaReplicationFactor(1)
.setIsPipeEnableMemoryCheck(false)
.setPipeAutoSplitFullEnabled(false);
receiverEnv.getConfig().getDataNodeConfig().setDataNodeMemoryProportion("3:3:1:1:9:1");
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 12960d70aeb..29655ceb24c 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
@@ -617,6 +617,7 @@ public class IoTDBPipeDataSinkIT extends
AbstractPipeDualTreeModelAutoIT {
receiverEnv,
"count timeseries root.sg_nonAligned.非对齐序列带有encoding和压缩方式.*",
"count(timeseries),",
- Collections.singleton("4,"));
+ Collections.singleton("4,"),
+ 20);
}
}