This is an automated email from the ASF dual-hosted git repository. liyuheng pushed a commit to branch lyh/fix-region-migration-IT in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3b09ba2c07209714fe43f67e2426acc2c37ecf61 Author: liyuheng <[email protected]> AuthorDate: Mon Oct 13 19:05:41 2025 +0800 fixed --- .../IoTDBRegionOperationReliabilityITFramework.java | 2 +- .../iotv1/IoTDBRegionMigrateDataNodeCrashForIoTV1IT.java | 13 +++++++------ .../IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT.java | 11 ++++++----- .../IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT.java | 11 ++++++----- .../daily/iotv1/IoTDBRegionMigrateClusterCrashIoTV1IT.java | 2 +- 5 files changed, 21 insertions(+), 18 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 8e2a954dc91..fb31828a794 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 @@ -580,7 +580,7 @@ public class IoTDBRegionOperationReliabilityITFramework { AtomicReference<SyncConfigNodeIServiceClient> clientRef = new AtomicReference<>(client); try { Awaitility.await() - .atMost(2, TimeUnit.MINUTES) + .atMost(4, TimeUnit.MINUTES) .pollDelay(2, TimeUnit.SECONDS) .until( () -> { diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv1/IoTDBRegionMigrateDataNodeCrashForIoTV1IT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv1/IoTDBRegionMigrateDataNodeCrashForIoTV1IT.java index f31e8f27dba..f70008e99e2 100644 --- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv1/IoTDBRegionMigrateDataNodeCrashForIoTV1IT.java +++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv1/IoTDBRegionMigrateDataNodeCrashForIoTV1IT.java @@ -28,6 +28,7 @@ import org.apache.iotdb.it.framework.IoTDBTestRunner; import org.apache.iotdb.itbase.category.DailyIT; import org.junit.Before; +import org.junit.Test; import org.junit.experimental.categories.Category; import org.junit.runner.RunWith; @@ -54,7 +55,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV1IT .setDataRegionConsensusProtocolClass(ConsensusFactory.IOT_CONSENSUS); } - // @Test + @Test public void coordinatorCrashDuringAddPeerTransition() throws Exception { failTest( 2, @@ -66,7 +67,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV1IT KillNode.COORDINATOR_DATANODE); } - // @Test + @Test public void coordinatorCrashDuringAddPeerDone() throws Exception { failTest( 2, @@ -82,7 +83,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV1IT // region Original DataNode crash tests - // @Test + @Test public void originalCrashDuringAddPeerDone() throws Exception { failTest( 2, @@ -98,7 +99,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV1IT // region Destination DataNode crash tests - // @Test + @Test public void destinationCrashDuringCreateLocalPeer() throws Exception { failTest( 2, @@ -110,7 +111,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV1IT KillNode.DESTINATION_DATANODE); } - // @Test + @Test public void destinationCrashDuringAddPeerTransition() throws Exception { failTest( 2, @@ -122,7 +123,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV1IT KillNode.DESTINATION_DATANODE); } - // @Test + @Test public void destinationCrashDuringAddPeerDone() throws Exception { failTest( 2, diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT.java index ad973814498..79a5ee3186c 100644 --- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT.java @@ -25,6 +25,7 @@ import org.apache.iotdb.confignode.it.regionmigration.IoTDBRegionOperationReliab import org.apache.iotdb.it.framework.IoTDBTestRunner; import org.apache.iotdb.itbase.category.DailyIT; +import org.junit.Test; import org.junit.experimental.categories.Category; import org.junit.runner.RunWith; @@ -41,7 +42,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT private final int configNodeNum = 1; private final int dataNodeNum = 3; - // @Test + @Test public void coordinatorCrashDuringAddPeerTransition() throws Exception { failTest( 2, @@ -53,7 +54,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT KillNode.COORDINATOR_DATANODE); } - // @Test + @Test public void coordinatorCrashDuringAddPeerDone() throws Exception { failTest( 2, @@ -69,7 +70,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT // region Original DataNode crash tests - // @Test + @Test public void originalCrashDuringAddPeerDone() throws Exception { failTest( 2, @@ -85,7 +86,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT // region Destination DataNode crash tests - // @Test + @Test public void destinationCrashDuringCreateLocalPeer() throws Exception { failTest( 2, @@ -97,7 +98,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT KillNode.DESTINATION_DATANODE); } - // @Test + @Test public void destinationCrashDuringAddPeerDone() throws Exception { failTest( 2, diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT.java index eeca6dacc19..f16d31bfb72 100644 --- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT.java @@ -28,6 +28,7 @@ import org.apache.iotdb.it.framework.IoTDBTestRunner; import org.apache.iotdb.itbase.category.DailyIT; import org.junit.Before; +import org.junit.Test; import org.junit.experimental.categories.Category; import org.junit.runner.RunWith; @@ -54,7 +55,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT .setIoTConsensusV2Mode(ConsensusFactory.IOT_CONSENSUS_V2_STREAM_MODE); } - // @Test + @Test public void coordinatorCrashDuringAddPeerTransition() throws Exception { failTest( 2, @@ -66,7 +67,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT KillNode.COORDINATOR_DATANODE); } - // @Test + @Test public void coordinatorCrashDuringAddPeerDone() throws Exception { failTest( 2, @@ -82,7 +83,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT // region Original DataNode crash tests - // @Test + @Test public void originalCrashDuringAddPeerDone() throws Exception { failTest( 2, @@ -98,7 +99,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT // region Destination DataNode crash tests - // @Test + @Test public void destinationCrashDuringCreateLocalPeer() throws Exception { failTest( 2, @@ -110,7 +111,7 @@ public class IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT KillNode.DESTINATION_DATANODE); } - // @Test + @Test public void destinationCrashDuringAddPeerDone() throws Exception { failTest( 2, diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateClusterCrashIoTV1IT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateClusterCrashIoTV1IT.java index e914483fa38..e7154561556 100644 --- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateClusterCrashIoTV1IT.java +++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv1/IoTDBRegionMigrateClusterCrashIoTV1IT.java @@ -73,7 +73,7 @@ public class IoTDBRegionMigrateClusterCrashIoTV1IT } // TODO: @Yongzao Dan, reopen this CI after discussion with @HxpSerein - // @Test + @Test public void clusterCrash7() throws Exception { killClusterTest(buildSet(RemoveRegionPeerState.DELETE_OLD_REGION_PEER), true); }
