(iotdb) branch feature/leader-write updated: remove consensus point calculate

[spricoder]

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

spricoder pushed a commit to branch feature/leader-write
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/feature/leader-write by this 
push:
     new 9a4bca0725a remove consensus point calculate
9a4bca0725a is described below

commit 9a4bca0725a42522a3ed34a9862c637b6357246d
Author: spricoder <sprico...@qq.com>
AuthorDate: Sun May 5 19:56:08 2024 +0800

    remove consensus point calculate
---
 .../db/consensus/statemachine/dataregion/DataRegionStateMachine.java  | 4 +++-
 .../apache/iotdb/db/queryengine/execution/load/LoadTsFileManager.java | 2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/statemachine/dataregion/DataRegionStateMachine.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/statemachine/dataregion/DataRegionStateMachine.java
index ae288312599..b16ad0abf7c 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/statemachine/dataregion/DataRegionStateMachine.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/consensus/statemachine/dataregion/DataRegionStateMachine.java
@@ -233,7 +233,9 @@ public class DataRegionStateMachine extends 
BaseStateMachine {
   @Override
   public TSStatus write(IConsensusRequest request) {
     try {
-      return write((PlanNode) request);
+      PlanNode planNode = (PlanNode) request;
+      planNode.markAsGeneratedByConsensus();
+      return write(planNode);
     } catch (IllegalArgumentException e) {
       logger.error(e.getMessage(), e);
       return new TSStatus(TSStatusCode.INTERNAL_SERVER_ERROR.getStatusCode());
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/LoadTsFileManager.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/LoadTsFileManager.java
index 5aca22f3179..c562f0ad860 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/LoadTsFileManager.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/LoadTsFileManager.java
@@ -328,7 +328,7 @@ public class LoadTsFileManager {
                   MemTableFlushTask.recordFlushPointsMetricInternal(
                       writePointCount, databaseName, 
dataRegion.getDataRegionId());
 
-                  // TODO @SpriCoder
+                  // TODO @SpriCoder check how load use consensus
                   MetricService.getInstance()
                       .count(
                           writePointCount,