This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch rc/1.3.5 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 097f725a90118a5a62191b00ff8f658b85e798b6 Author: Caideyipi <[email protected]> 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 28660fd0e5d..c7990b24d45 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 @@ -170,6 +170,7 @@ public class LoadTsFileDispatcherImpl implements IFragInstanceDispatcher { final TsFileResource tsFileResource = ((LoadSingleTsFileNode) planNode).getTsFileResource(); try { PipeDataNodeAgent.runtime().assignProgressIndexForTsFileLoad(tsFileResource); + tsFileResource.setGeneratedByPipe(isGeneratedByPipe); tsFileResource.serialize(); StorageEngine.getInstance()
