This is an automated email from the ASF dual-hosted git repository. CRZbulabula pushed a commit to branch yongzao/fix-iotv1-follower-sync in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c885b548708a731b8ed24d874a20a9b5f49aed8f Author: Yongzao <[email protected]> AuthorDate: Thu Aug 27 19:16:03 2026 +0800 Fix IoTConsensus reconstruction IT follower synchronization --- .../commit/IoTDBRegionReconstructForIoTV1IT.java | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionReconstructForIoTV1IT.java b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionReconstructForIoTV1IT.java index dbe8e529719..2f3ba682135 100644 --- a/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionReconstructForIoTV1IT.java +++ b/integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionReconstructForIoTV1IT.java @@ -45,6 +45,7 @@ import org.slf4j.LoggerFactory; import java.io.File; import java.sql.Connection; +import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.Collections; @@ -148,6 +149,25 @@ public class IoTDBRegionReconstructForIoTV1IT extends IoTDBRegionOperationReliab .get() .getDataPath()); + DataNodeWrapper followerNode = + EnvFactory.getEnv().dataNodeIdToWrapper(dataNodeToBeReconstructed).orElseThrow(); + Awaitility.await() + .pollInterval(1, TimeUnit.SECONDS) + .atMost(1, TimeUnit.MINUTES) + .untilAsserted( + () -> { + try (Connection followerConnection = + EnvFactory.getEnv().getConnection(followerNode); + Statement followerStatement = followerConnection.createStatement(); + ResultSet resultSet = + followerStatement.executeQuery( + "select speed, temperature from root.sg.d1")) { + Assert.assertTrue(resultSet.next()); + Assert.assertEquals(1.0, resultSet.getDouble("speed"), 0.0); + Assert.assertEquals(2.0, resultSet.getDouble("temperature"), 0.0); + } + }); + EnvFactory.getEnv().dataNodeIdToWrapper(dataNodeToBeClosed).get().stopForcibly(); while (true) {
