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 <[email protected]> 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()); }
