[iotdb] branch ml_0729_test updated: add stepTracker

[xingtanzjr]

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

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


The following commit(s) were added to refs/heads/ml_0729_test by this push:
     new 068d12d4c5 add stepTracker
068d12d4c5 is described below

commit 068d12d4c58dce9231556587f67fa03a0151d118
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Mon Aug 1 12:22:36 2022 +0800

    add stepTracker
---
 .../apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
 
b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
index adad0a8b98..e0b67984d0 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/DataRegionStateMachine.java
@@ -33,6 +33,7 @@ import org.apache.iotdb.db.engine.snapshot.SnapshotLoader;
 import org.apache.iotdb.db.engine.snapshot.SnapshotTaker;
 import org.apache.iotdb.db.engine.storagegroup.DataRegion;
 import org.apache.iotdb.db.mpp.execution.fragment.FragmentInstanceManager;
+import org.apache.iotdb.db.mpp.plan.StepTracker;
 import org.apache.iotdb.db.mpp.plan.planner.plan.FragmentInstance;
 import org.apache.iotdb.db.mpp.plan.planner.plan.node.PlanNode;
 import 
org.apache.iotdb.db.mpp.plan.planner.plan.node.write.InsertMultiTabletsNode;
@@ -181,9 +182,11 @@ public class DataRegionStateMachine extends 
BaseStateMachine {
           insertNodes.add(innerNode);
         }
         if (indexedRequest.getSearchIndex() == 
ConsensusReqReader.DEFAULT_SEARCH_INDEX) {
+          long cacheRequestStartTime = System.nanoTime();
           planNode =
               cacheAndGetLatestInsertNode(
                   indexedRequest.getSyncIndex(), 
mergeInsertNodes(insertNodes));
+          StepTracker.trace("cacheAndQueueRequest", cacheRequestStartTime, 
System.nanoTime());
         } else {
           planNode = mergeInsertNodes(insertNodes);
         }