(iotdb) branch pipe-flush updated: hybrid

[justinchen]

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

justinchen pushed a commit to branch pipe-flush
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/pipe-flush by this push:
     new 7b637991817 hybrid
7b637991817 is described below

commit 7b6379918178794aaf143e941e50aa0b445603a4
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Fri Feb 13 16:19:54 2026 +0800

    hybrid
---
 .../source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java   | 1 +
 .../realtime/assigner/PipeTsFileEpochProgressIndexAndFlushManager.java   | 1 +
 2 files changed, 2 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java
index f3457ac79f9..5bf5e3fd4a5 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/PipeRealtimeDataRegionHybridSource.java
@@ -65,6 +65,7 @@ public class PipeRealtimeDataRegionHybridSource extends 
PipeRealtimeDataRegionSo
               "Unsupported event type %s for hybrid realtime extractor %s",
               eventToExtract.getClass(), this));
     }
+    
PipeTsFileEpochProgressIndexAndFlushManager.getInstance().flushAllTimeoutTsFiles();
   }
 
   @Override
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/PipeTsFileEpochProgressIndexAndFlushManager.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/PipeTsFileEpochProgressIndexAndFlushManager.java
index 27d549daf61..677fc92710a 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/PipeTsFileEpochProgressIndexAndFlushManager.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/PipeTsFileEpochProgressIndexAndFlushManager.java
@@ -76,6 +76,7 @@ public class PipeTsFileEpochProgressIndexAndFlushManager {
                                     .getDataRegion(new DataRegionId(regionId))
                                     .asyncCloseOneTsFileProcessor(
                                         pair.getLeft().isSeq(), 
pair.getLeft().getProcessor());
+                                pair.setRight(Long.MAX_VALUE);
                               }
                             })));
   }