You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2026/06/16 07:09:01 UTC
(iotdb) 01/01: Fix per-database region allocation IT timeout
This is an automated email from the ASF dual-hosted git repository.
CRZbulabula pushed a commit to branch fix-region-allocation-it-timeout
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 39f89f52f0329af33d736158108f034f9274c6b0
Author: Yongzao <53...@qq.com>
AuthorDate: Tue Jun 16 15:08:21 2026 +0800
Fix per-database region allocation IT timeout
---
.../it/load/IoTDBPerDatabaseRegionGroupAllocationIT.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/load/IoTDBPerDatabaseRegionGroupAllocationIT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/load/IoTDBPerDatabaseRegionGroupAllocationIT.java
index 94b67fa8f53..da4f9cfcc0f 100644
--- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/load/IoTDBPerDatabaseRegionGroupAllocationIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/load/IoTDBPerDatabaseRegionGroupAllocationIT.java
@@ -80,8 +80,9 @@ public class IoTDBPerDatabaseRegionGroupAllocationIT {
.setDataReplicationFactor(TEST_REPLICATION_FACTOR)
.setDataRegionGroupExtensionPolicy("CUSTOM")
.setDefaultDataRegionGroupNumPerDatabase(TEST_DATA_REGION_GROUP_NUM_PER_DATABASE)
- // Avoid auto leader balancing rearranging anything during the test
- .setEnableAutoLeaderBalanceForIoTConsensus(false);
+ // This test only checks replica placement. Keep leader balance enabled so IoTConsensus
+ // RegionGroups become ready before the CreateRegionGroupsProcedure wait timeout expires.
+ .setEnableAutoLeaderBalanceForIoTConsensus(true);
EnvFactory.getEnv().initClusterEnvironment(1, TEST_DATA_NODE_NUM);
}
@@ -128,6 +129,10 @@ public class IoTDBPerDatabaseRegionGroupAllocationIT {
TDataPartitionTableResp dataPartitionTableResp =
client.getOrCreateDataPartitionTable(new TDataPartitionReq(partitionSlotsMap));
Assert.assertEquals(
+ "Failed to create DataPartitions for "
+ + currentDatabase
+ + ": "
+ + dataPartitionTableResp.getStatus(),
TSStatusCode.SUCCESS_STATUS.getStatusCode(),
dataPartitionTableResp.getStatus().getCode());
}