[iotdb] branch ml_0729_test_exp1 updated: change log rate for follower write

[xingtanzjr]

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

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


The following commit(s) were added to refs/heads/ml_0729_test_exp1 by this push:
     new 146c2d2940 change log rate for follower write
146c2d2940 is described below

commit 146c2d294003a24bb3dc8b32d97a06ce46e7836f
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Fri Aug 5 09:44:37 2022 +0800

    change log rate for follower write
---
 .../iotdb/db/consensus/statemachine/DataRegionStateMachine.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 8d403b5c4c..36029e2130 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
@@ -181,8 +181,8 @@ public class DataRegionStateMachine extends 
BaseStateMachine {
       InsertNodeWrapper insertNodeWrapper =
           cacheAndGetLatestInsertNode(
               requests.get(0).getSyncIndex(), insertNodesInAllRequests, 
resultHandler);
-      StepTracker.trace("cacheAndGet", startTime, System.nanoTime());
-      StepTracker.trace("followerWritePrepare", prepareStartTime, 
System.nanoTime());
+      StepTracker.trace("cacheAndGet", 25, startTime, System.nanoTime());
+      StepTracker.trace("followerWritePrepare", 25, prepareStartTime, 
System.nanoTime());
       long writeStartTime = System.nanoTime();
       if (insertNodeWrapper != null) {
         for (InsertNode insertNode : insertNodeWrapper.getInsertNodes()) {
@@ -190,7 +190,7 @@ public class DataRegionStateMachine extends 
BaseStateMachine {
         }
         insertNodeWrapper.resultHandler.onComplete(new TSyncLogRes(statuses));
       }
-      StepTracker.trace("followerWriteInsert", writeStartTime, 
System.nanoTime());
+      StepTracker.trace("followerWriteInsert", 25, writeStartTime, 
System.nanoTime());
     } catch (IllegalArgumentException e) {
       logger.error(e.getMessage(), e);
       resultHandler.onError(e);