(iotdb) branch master updated: Pipe: Fixed the bug that non-forwarding flag does not take effect on insertRowsNode / insertRowsOfOneDevicesNode (#12824)

[rong]

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

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new c4828465214 Pipe: Fixed the bug that non-forwarding flag does not take 
effect on insertRowsNode / insertRowsOfOneDevicesNode (#12824)
c4828465214 is described below

commit c48284652144eaeeacb40340710cae637f08dca2
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Jun 27 22:35:57 2024 +0800

    Pipe: Fixed the bug that non-forwarding flag does not take effect on 
insertRowsNode / insertRowsOfOneDevicesNode (#12824)
---
 .../org/apache/iotdb/db/storageengine/dataregion/DataRegion.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index 89d11f94adc..9f7252bd98c 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -1202,6 +1202,9 @@ public class DataRegion implements IDataRegionForQuery {
               v = new InsertRowsNode(insertRowsNode.getPlanNodeId());
               v.setSearchIndex(insertRowNode.getSearchIndex());
               v.setAligned(insertRowNode.isAligned());
+              if (insertRowNode.isGeneratedByPipe()) {
+                v.markAsGeneratedByPipe();
+              }
             }
             v.addOneInsertRowNode(insertRowNode, finalI);
             v.updateProgressIndex(insertRowNode.getProgressIndex());
@@ -3302,6 +3305,9 @@ public class DataRegion implements IDataRegionForQuery {
                 v = new 
InsertRowsNode(insertRowsOfOneDeviceNode.getPlanNodeId());
                 v.setSearchIndex(insertRowNode.getSearchIndex());
                 v.setAligned(insertRowNode.isAligned());
+                if (insertRowNode.isGeneratedByPipe()) {
+                  v.markAsGeneratedByPipe();
+                }
               }
               v.addOneInsertRowNode(insertRowNode, finalI);
               v.updateProgressIndex(insertRowNode.getProgressIndex());