You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/08/05 01:44:47 UTC
[iotdb] branch ml_0729_test_exp1 updated: change log rate for follower write
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 <xi...@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);