Skip to content

Commit 08b4f8f

Browse files
authored
Pipe: Fixed the ping-pong of certain realtime tsFiles
1 parent f693475 commit 08b4f8f

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImpl.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -172,6 +172,7 @@ public void dispatchLocally(FragmentInstance instance) throws FragmentInstanceDi
172172
final TsFileResource tsFileResource = ((LoadSingleTsFileNode) planNode).getTsFileResource();
173173
try {
174174
PipeDataNodeAgent.runtime().assignProgressIndexForTsFileLoad(tsFileResource);
175+
tsFileResource.setGeneratedByPipe(isGeneratedByPipe);
175176
tsFileResource.serialize();
176177

177178
StorageEngine.getInstance()

0 commit comments

Comments
 (0)