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 2026/08/27 11:16:35 UTC
(iotdb) branch yongzao/fix-iotv1-follower-sync created (now c885b548708)
This is an automated email from the ASF dual-hosted git repository.
CRZbulabula pushed a change to branch yongzao/fix-iotv1-follower-sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at c885b548708 Fix IoTConsensus reconstruction IT follower synchronization
This branch includes the following new commits:
new c885b548708 Fix IoTConsensus reconstruction IT follower synchronization
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: Fix IoTConsensus reconstruction IT follower synchronization
Posted by yo...@apache.org.
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 <53...@qq.com>
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) {