(iotdb) branch master updated: Revert "[Test] Fix deletion regression test flush control"

[justinchen]

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

Caideyipi 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 6402cd9594b Revert "[Test] Fix deletion regression test flush control"
6402cd9594b is described below

commit 6402cd9594bbbe459e8d7d80b0b9f7c1753f7379
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Oct 15 16:13:01 2026 +0800

    Revert "[Test] Fix deletion regression test flush control"
    
    This reverts commit 264053f1423fc2174f64a6fbcf8312d533eeb199.
---
 .../dataregion/memtable/TsFileProcessorTest.java             | 12 ++++--------
 1 file changed, 4 insertions(+), 8 deletions(-)

diff --git 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessorTest.java
 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessorTest.java
index 61a672ebdcf..324bf78a37e 100644
--- 
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessorTest.java
+++ 
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessorTest.java
@@ -229,16 +229,14 @@ public class TsFileProcessorTest {
               SystemFileFactory.INSTANCE.getFile(filePath),
               sgInfo,
               this::closeTsFileProcessor,
-              (tsFileProcessor, updateMap, systemFlushTime) -> {
-                // Take over flushing after asyncClose's guard, before 
FlushManager registration.
-                tsFileProcessor.setManagedByFlushManager(true);
-              },
+              (tsFileProcessor, updateMap, systemFlushTime) -> {},
               true);
       processor.setTsFileProcessorInfo(new TsFileProcessorInfo(sgInfo));
       sgInfo.initTsFileProcessorInfo(processor);
       TSRecord record = new TSRecord(deviceId, 1);
       record.addTuple(DataPoint.getDataPoint(dataType, measurementId, "1"));
       processor.insert(buildInsertRowNodeByTSRecord(record), new long[5]);
+      processor.setManagedByFlushManager(true);
       processor.asyncClose();
       Assert.assertNull(processor.getWorkMemTable());
 
@@ -314,10 +312,7 @@ public class TsFileProcessorTest {
               SystemFileFactory.INSTANCE.getFile(filePath),
               sgInfo,
               this::closeTsFileProcessor,
-              (tsFileProcessor, updateMap, systemFlushTime) -> {
-                // Take over flushing after asyncClose's guard, before 
FlushManager registration.
-                tsFileProcessor.setManagedByFlushManager(true);
-              },
+              (tsFileProcessor, updateMap, systemFlushTime) -> {},
               true);
       processor.setTsFileProcessorInfo(new TsFileProcessorInfo(sgInfo));
       sgInfo.initTsFileProcessorInfo(processor);
@@ -336,6 +331,7 @@ public class TsFileProcessorTest {
       logDeletionForTest(tableModel, 2);
 
       // Use the production close path, while keeping flush execution under 
test control.
+      processor.setManagedByFlushManager(true);
       try {
         processor.asyncClose();
         Assert.assertNull(processor.getWorkMemTable());