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;