(iotdb) branch master updated: Add logs for migration related daily IT (#16175)

[yongzao]

This is an automated email from the ASF dual-hosted git repository.

yongzao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new c030c64036e Add logs for migration related daily IT (#16175)
c030c64036e is described below

commit c030c64036eac13c76599ed2d6208cad0358399b
Author: Yongzao <yong...@apache.org>
AuthorDate: Thu Aug 14 18:21:15 2025 +0800

    Add logs for migration related daily IT (#16175)
---
 .../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);
   }