From ab2d1e4214db2c92e188de327ad1f00a00f05cef Mon Sep 17 00:00:00 2001
From: Caideyipi <87789683+Caideyipi@users.noreply.github.com>
Date: Tue, 15 Jul 2025 23:47:18 +0800
Subject: [PATCH] Update LoadTsFileDispatcherImpl.java

---
 .../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 41b003c5b77b6..77226615e2706 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 void dispatchLocally(FragmentInstance instance) throws FragmentInstanceDi
       final TsFileResource tsFileResource = ((LoadSingleTsFileNode) planNode).getTsFileResource();
       try {
         PipeDataNodeAgent.runtime().assignProgressIndexForTsFileLoad(tsFileResource);
+        tsFileResource.setGeneratedByPipe(isGeneratedByPipe);
         tsFileResource.serialize();
 
         StorageEngine.getInstance()