(iotdb) branch master updated: Mark InsertRowsNode's isGeneratedFromRemoteConsensusLeader for Last Cache Optimization #12838

[ta...@apache.org]

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

tanxinyu 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 555f79c84f0 Mark InsertRowsNode's isGeneratedFromRemoteConsensusLeader for Last Cache Optimization #12838
555f79c84f0 is described below

commit 555f79c84f0f59ba3596177c0eeccb02320e219d
Author: Peng Junzhi <78...@users.noreply.github.com>
AuthorDate: Mon Jul 1 23:27:25 2024 -0500

    Mark InsertRowsNode's isGeneratedFromRemoteConsensusLeader for Last Cache Optimization #12838
---
 .../java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java  | 3 +++
 1 file changed, 3 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 733eca443d7..80129eae0fc 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
@@ -1203,6 +1203,9 @@ public class DataRegion implements IDataRegionForQuery {
               if (insertRowNode.isGeneratedByPipe()) {
                 v.markAsGeneratedByPipe();
               }
+              if (insertRowNode.isGeneratedByRemoteConsensusLeader()) {
+                v.markAsGeneratedByRemoteConsensusLeader();
+              }
             }
             v.addOneInsertRowNode(insertRowNode, finalI);
             v.updateProgressIndex(insertRowNode.getProgressIndex());