This is an automated email from the ASF dual-hosted git repository. jt2594838 pushed a commit to branch fix_wal_node_test_stability in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d0f17786b9d36e34ba19fab829ee98e4af5390ce Author: Tian Jiang <[email protected]> AuthorDate: Thu Jul 16 17:41:40 2026 +0800 Fix flaky WALNodeTest WAL roll assertion --- .../iotdb/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 e3d1efb4edd..f1627611116 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 class WALNodeTest { 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(
