diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALNodeTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALNodeTest.java index 210ee544ea47..58411bdc9afd 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALNodeTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/node/WALNodeTest.java @@ -362,10 +362,6 @@ public void testDeleteOutdatedFiles() throws Exception { walNode.rollWALFile(); walNode.onMemTableCreated(new PrimitiveMemTable(databasePath, dataRegionId), tsFilePath); Awaitility.await().until(() -> walNode.isAllWALEntriesConsumed()); - // Wait for the sync task to finish rolling the WAL writer before checking the file names. - for (WALFlushListener walFlushListener : walFlushListeners) { - assertEquals(WALFlushListener.Status.SUCCESS, walFlushListener.waitForResult()); - } // check existence of _0-0-0.wal file and _1-0-1.wal file assertTrue( new File(