This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch enhance-regionreconstructIT in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cf3efe950ea2901cdd0d2f458073b5a786465a08 Author: Yongzao <[email protected]> AuthorDate: Thu Jul 31 10:16:42 2025 +0800 Update IoTDBRegionReconstructForIoTV1IT.java --- .../pass/commit/IoTDBRegionReconstructForIoTV1IT.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) 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 c422444383a..777b1d2d652 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 @@ -192,7 +192,7 @@ public class IoTDBRegionReconstructForIoTV1IT extends IoTDBRegionOperationReliab // now, the query should work fine, but the update of region status may have some delay long start = System.currentTimeMillis(); while (true) { - SessionDataSet resultSet = null; + SessionDataSet resultSet; try { resultSet = session.executeQueryStatement("select * from root.sg.**"); } catch (StatementExecutionException e) { @@ -201,10 +201,12 @@ public class IoTDBRegionReconstructForIoTV1IT extends IoTDBRegionOperationReliab } continue; } - RowRecord rowRecord = resultSet.next(); - Assert.assertEquals("2.0", rowRecord.getField(0).getStringValue()); - Assert.assertEquals("1.0", rowRecord.getField(1).getStringValue()); - break; + if (resultSet.hasNext()) { + RowRecord rowRecord = resultSet.next(); + Assert.assertEquals("2.0", rowRecord.getField(0).getStringValue()); + Assert.assertEquals("1.0", rowRecord.getField(1).getStringValue()); + break; + } } } }
