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

hxd pushed a commit to branch rel/0.13
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/0.13 by this push:
     new 24b855ab13 [IOTDB-4577] Check archiving result after all tasks are 
finished (#7546)
24b855ab13 is described below

commit 24b855ab137162f7b193b51f45943fb6cde32753
Author: Alan Choo <[email protected]>
AuthorDate: Sat Oct 8 19:00:52 2022 +0800

    [IOTDB-4577] Check archiving result after all tasks are finished (#7546)
---
 .../test/java/org/apache/iotdb/db/integration/IoTDBArchivingIT.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBArchivingIT.java
 
b/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBArchivingIT.java
index 6b31855666..1b01376a14 100644
--- 
a/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBArchivingIT.java
+++ 
b/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBArchivingIT.java
@@ -128,7 +128,7 @@ public class IoTDBArchivingIT {
       statement.execute(
           "SET ARCHIVING TO root.ARCHIVING_SG1 1999-01-01 1000 '" + 
testTargetDir.getPath() + "'");
 
-      Thread.sleep(ARCHIVING_CHECK_TIME * 2);
+      waitUntilAllFinished();
 
       try (ResultSet resultSet = statement.executeQuery("SELECT s1 FROM 
root.ARCHIVING_SG1")) {
         int cnt = 0;
@@ -182,7 +182,7 @@ public class IoTDBArchivingIT {
 
       
StorageEngine.getInstance().getArchivingManager().setCheckThreadTime(ARCHIVING_CHECK_TIME);
 
-      Thread.sleep(ARCHIVING_CHECK_TIME * 2);
+      waitUntilAllFinished();
 
       try (ResultSet resultSet = statement.executeQuery("SELECT s1 FROM 
root.ARCHIVING_SG1")) {
         int cnt = 0;

Reply via email to