This is an automated email from the ASF dual-hosted git repository. jiangtian pushed a commit to branch fix_tsfile_processor_test in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8088cee68906135d8a2f4be2f519b5e2d3b14335 Author: Tian Jiang <[email protected]> AuthorDate: Sat Feb 28 15:38:11 2026 +0800 Fixed TsFileProcessorTest may check the result before the TsFile is closed --- .../iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java index 518df5322a9..bfaa8bc12d7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java @@ -1353,7 +1353,7 @@ public class TsFileProcessor { dataRegionName, tsFileResource.getTsFile().getName()); } - addAMemtableIntoFlushingList(tmpMemTable); + closeFuture = addAMemtableIntoFlushingList(tmpMemTable); } finally { flushQueryLock.writeLock().unlock(); logFlushQueryWriteUnlocked(); @@ -1393,7 +1393,7 @@ public class TsFileProcessor { } logger.info( "Async flush a memtable to tsfile: {}", tsFileResource.getTsFile().getAbsolutePath()); - addAMemtableIntoFlushingList(workMemTable); + closeFuture = addAMemtableIntoFlushingList(workMemTable); } catch (Exception e) { logger.error( "{}: {} add a memtable into flushing list failed",
