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 e3d1efb4edd19..f16276111162e 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 @@ -366,6 +366,10 @@ public void testDeleteOutdatedFiles() throws Exception { walNode.onMemTableFlushed(memTable); 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(