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

jiangtian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 8cd57abda1d fix CompactionTaskManager ut (#12923)
8cd57abda1d is described below

commit 8cd57abda1dd54863e1fd6ac00f9f23eed3c9ddf
Author: shuwenwei <55970239+shuwen...@users.noreply.github.com>
AuthorDate: Fri Jul 19 14:16:50 2024 +0800

    fix CompactionTaskManager ut (#12923)
---
 .../dataregion/compaction/CompactionTaskManagerTest.java             | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionTaskManagerTest.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionTaskManagerTest.java
index 25fb01c5e25..d70c4665313 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionTaskManagerTest.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionTaskManagerTest.java
@@ -102,14 +102,11 @@ public class CompactionTaskManagerTest extends 
InnerCompactionTest {
     } finally {
       seqResources.get(0).readUnlock();
     }
-    if (summaryFuture != null) {
-      summaryFuture.get();
-    }
+    manager.waitAllCompactionFinish();
     Assert.assertEquals(0, manager.getTotalTaskCount());
     for (TsFileResource resource : seqResources) {
       Assert.assertFalse(resource.isCompactionCandidate());
     }
-    manager.waitAllCompactionFinish();
   }
 
   @Test

Reply via email to