(iotdb) branch pipe-flush updated: ky-only

[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 5a5dd75b92b ky-only
5a5dd75b92b is described below

commit 5a5dd75b92b5641996774e2817696f30a79be4df
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Fri Feb 13 19:02:01 2026 +0800

    ky-only
---
 .../realtime/assigner/PipeTsFileEpochProgressIndexAndFlushManager.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

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 20b2dfe410f..a3d81ab46dc 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
@@ -74,8 +74,7 @@ public class PipeTsFileEpochProgressIndexAndFlushManager {
                                   >= pair.getRight()) {
                                 StorageEngine.getInstance()
                                     .getDataRegion(new DataRegionId(regionId))
-                                    .asyncCloseOneTsFileProcessor(
-                                        pair.getLeft().isSeq(), 
pair.getLeft().getProcessor());
+                                    
.asyncCloseOneTsFileProcessor(pair.getLeft());
                                 pair.setRight(Long.MAX_VALUE);
                               }
                             })));