(iotdb) branch master updated: Fix flaky WALNodeTest WAL roll assertion (#18226)

[jiangtian]

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

jt2594838 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 2f7505ffba3 Fix flaky WALNodeTest WAL roll assertion (#18226)
2f7505ffba3 is described below

commit 2f7505ffba3c49c0a3d843e950f36e139f8e7ea4
Author: Jiang Tian <jt2594...@163.com>
AuthorDate: Thu Jul 16 18:39:10 2026 +0800

    Fix flaky WALNodeTest WAL roll assertion (#18226)
---
 .../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(