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 2025/08/14 05:54:18 UTC
(iotdb) branch fix-migrate-daily-IT created (now d8c63cefb0a)
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch fix-migrate-daily-IT
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at d8c63cefb0a trigger CI
This branch includes the following new commits:
new d8c63cefb0a trigger CI
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: trigger CI
Posted by yo...@apache.org.
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 <53...@qq.com>
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);
}