This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch fix-migrate-daily-IT in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d8c63cefb0a83e870bee1c9420bc0634c8aa7aa4 Author: Yongzao <[email protected]> AuthorDate: Thu Aug 14 13:54:06 2025 +0800 trigger CI --- .../IoTDBRegionOperationReliabilityITFramework.java | 3 +++ .../commit/IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 14 ++++++++++++-- 2 files changed, 15 insertions(+), 2 deletions(-) diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/IoTDBRegionOperationReliabilityITFramework.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/IoTDBRegionOperationReliabilityITFramework.java index 224dcf890dd..25436bb103e 100644 --- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/IoTDBRegionOperationReliabilityITFramework.java +++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/IoTDBRegionOperationReliabilityITFramework.java @@ -276,6 +276,7 @@ public class IoTDBRegionOperationReliabilityITFramework { try { awaitUntilSuccess( client, + selectedRegion, migrateRegionPredicate, Optional.of(destDataNode), Optional.of(originalDataNode)); @@ -563,6 +564,7 @@ public class IoTDBRegionOperationReliabilityITFramework { protected static void awaitUntilSuccess( SyncConfigNodeIServiceClient client, + int selectedRegion, Predicate<TShowRegionResp> predicate, Optional<Integer> dataNodeExpectInRegionGroup, Optional<Integer> dataNodeExpectNotInRegionGroup) { @@ -577,6 +579,7 @@ public class IoTDBRegionOperationReliabilityITFramework { () -> { try { TShowRegionResp resp = clientRef.get().showRegion(new TShowRegionReq()); + lastTimeDataNodes.set(getRegionMap(resp.getRegionInfoList()).get(selectedRegion)); return predicate.test(resp); } catch (TException e) { clientRef.set( diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java index 07a84d96657..c1702ee701d 100644 --- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java +++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java @@ -139,7 +139,12 @@ public class IoTDBRegionGroupExpandAndShrinkForIoTV1IT return dataNodes.contains(targetDataNode); }; - awaitUntilSuccess(client, expandRegionPredicate, Optional.of(targetDataNode), Optional.empty()); + awaitUntilSuccess( + client, + selectedRegion, + expandRegionPredicate, + Optional.of(targetDataNode), + Optional.empty()); LOGGER.info("Region {} has expanded to DataNode {}", selectedRegion, targetDataNode); } @@ -167,7 +172,12 @@ public class IoTDBRegionGroupExpandAndShrinkForIoTV1IT return !dataNodes.contains(targetDataNode); }; - awaitUntilSuccess(client, shrinkRegionPredicate, Optional.empty(), Optional.of(targetDataNode)); + awaitUntilSuccess( + client, + selectedRegion, + shrinkRegionPredicate, + Optional.empty(), + Optional.of(targetDataNode)); LOGGER.info("Region {} has shrunk from DataNode {}", selectedRegion, targetDataNode); }
