From d0f17786b9d36e34ba19fab829ee98e4af5390ce Mon Sep 17 00:00:00 2001 From: Tian Jiang Date: Thu, 16 Jul 2026 17:41:40 +0800 Subject: [PATCH] Fix flaky WALNodeTest WAL roll assertion --- .../db/storageengine/dataregion/wal/node/WALNodeTest.java | 4 ++++ 1 file changed, 4 insertions(+) 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(