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 e3d1efb4edd1..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 @@ -332,9 +332,7 @@ public void testConcurrentCheckpoint() throws Exception { @Test public void testDeleteOutdatedFiles() throws Exception { - List walFlushListeners = new ArrayList<>(); - // write until log is rolled - long time = 0; + // write data to make the first WAL file non-empty IMemTable memTable = new PrimitiveMemTable(databasePath, dataRegionId); long memTableId = memTable.getMemTableId(); String tsFilePath = @@ -352,18 +350,16 @@ public void testDeleteOutdatedFiles() throws Exception { .setDataRegion( new DataRegionId(1), new DataRegionTest.DummyDataRegion(logDirectory, databasePath)); walNode.onMemTableCreated(memTable, tsFilePath); - while (time < 20000) { - ++time; + for (long time = 1; time <= 100; ++time) { InsertTabletNode insertTabletNode = getInsertTabletNode(devicePath + memTableId, new long[] {time}); - WALFlushListener walFlushListener = - walNode.log( - memTableId, - insertTabletNode, - Collections.singletonList(new int[] {0, insertTabletNode.getRowCount()})); - walFlushListeners.add(walFlushListener); + walNode.log( + memTableId, + insertTabletNode, + Collections.singletonList(new int[] {0, insertTabletNode.getRowCount()})); } walNode.onMemTableFlushed(memTable); + walNode.rollWALFile(); walNode.onMemTableCreated(new PrimitiveMemTable(databasePath, dataRegionId), tsFilePath); Awaitility.await().until(() -> walNode.isAllWALEntriesConsumed()); // check existence of _0-0-0.wal file and _1-0-1.wal file