(iotdb) branch dev/1.3 updated: Pipe: Fixed the ping-pong of certain realtime tsFiles (#15949)

[justinchen]

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

justinchen pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 65787b7c2e4 Pipe: Fixed the ping-pong of certain realtime tsFiles 
(#15949)
65787b7c2e4 is described below

commit 65787b7c2e48a0ac437737e21b9b73857d7aaca4
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Tue Jul 15 23:56:33 2025 +0800

    Pipe: Fixed the ping-pong of certain realtime tsFiles (#15949)
---
 .../db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImpl.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImpl.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImpl.java
index 41b003c5b77..77226615e27 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImpl.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImpl.java
@@ -172,6 +172,7 @@ public class LoadTsFileDispatcherImpl implements 
IFragInstanceDispatcher {
       final TsFileResource tsFileResource = ((LoadSingleTsFileNode) 
planNode).getTsFileResource();
       try {
         
PipeDataNodeAgent.runtime().assignProgressIndexForTsFileLoad(tsFileResource);
+        tsFileResource.setGeneratedByPipe(isGeneratedByPipe);
         tsFileResource.serialize();
 
         StorageEngine.getInstance()