You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yu...@apache.org on 2020/09/01 10:43:09 UTC
[incubator-iotdb] branch cluster_performance updated: follower
report
This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a commit to branch cluster_performance
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/cluster_performance by this push:
new bf5c4cf follower report
bf5c4cf is described below
commit bf5c4cf1c4dda79ca99d16d47338d63c31cae93d
Author: Ring-k <yu...@hotmail.com>
AuthorDate: Tue Sep 1 18:42:48 2020 +0800
follower report
---
.../java/org/apache/iotdb/cluster/server/Timer.java | 17 +++++++++++++----
.../apache/iotdb/cluster/server/member/RaftMember.java | 2 +-
2 files changed, 14 insertions(+), 5 deletions(-)
diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/Timer.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/Timer.java
index 1bc6b34..7ae3620 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/Timer.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/Timer.java
@@ -31,22 +31,26 @@ public class Timer {
private static final String raftMemberAppendLogMSString = "Raft member - append log: ";
private static final String raftMemberSendLogToFollowerMSString = "Raft member - send log to follower: ";
private static final String raftMemberCommitLogMSString = "Raft member - commit log: ";
+ private static final String raftFollowerAppendEntryString = "Raft member - follower append entry: ";
public static String getReport() {
String result = "";
result += dataGroupMemberProcessPlanLocallyMSString
+ dataGroupMemberProcessPlanLocallyMS + ", "
+ dataGroupMemberProcessPlanLocallyCounter + ", "
- + (double)dataGroupMemberProcessPlanLocallyMS.get() / dataGroupMemberProcessPlanLocallyCounter.get()
+ + (double) dataGroupMemberProcessPlanLocallyMS.get()
+ / dataGroupMemberProcessPlanLocallyCounter.get()
+ "\n";
result += dataGroupMemberWaitLeaderMSString
+ dataGroupMemberWaitLeaderMS + ", "
+ dataGroupMemberWaitLeaderCounter + ", "
- + (double) dataGroupMemberWaitLeaderMS.get() / dataGroupMemberWaitLeaderCounter.get() + "\n";
+ + (double) dataGroupMemberWaitLeaderMS.get() / dataGroupMemberWaitLeaderCounter.get()
+ + "\n";
result += metaGroupMemberExecuteNonQueryMSString
+ metaGroupMemberExecuteNonQueryMS + ", "
+ metaGroupMemberExecuteNonQueryCounter + ", "
- + (double) metaGroupMemberExecuteNonQueryMS.get() / metaGroupMemberExecuteNonQueryCounter.get() + "\n";
+ + (double) metaGroupMemberExecuteNonQueryMS.get() / metaGroupMemberExecuteNonQueryCounter
+ .get() + "\n";
result += metaGroupMemberExecuteNonQueryInLocalGroupMSString
+ metaGroupMemberExecuteNonQueryInLocalGroupMS + ", "
+ metaGroupMemberExecuteNonQueryInLocalGroupCounter + ", "
@@ -64,11 +68,16 @@ public class Timer {
result += raftMemberSendLogToFollowerMSString
+ raftMemberSendLogToFollowerMS + ", "
+ raftMemberSendLogToFollowerCounter + ", "
- + (double) raftMemberSendLogToFollowerMS.get() / raftMemberSendLogToFollowerCounter.get() + "\n";
+ + (double) raftMemberSendLogToFollowerMS.get() / raftMemberSendLogToFollowerCounter.get()
+ + "\n";
result += raftMemberCommitLogMSString
+ raftMemberCommitLogMS + ", "
+ raftMemberCommitLogCounter + ", "
+ (double) raftMemberCommitLogMS.get() / raftMemberCommitLogCounter.get() + "\n";
+ result += raftFollowerAppendEntryString
+ + raftFollowerAppendEntryMS + ", "
+ + raftFollowerAppendEntryCounter + ", "
+ + (double) raftFollowerAppendEntryMS.get() / raftFollowerAppendEntryCounter.get() + "\n";
return result;
}
diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
index ddc7ea4..6620f72 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
@@ -497,7 +497,7 @@ public abstract class RaftMember {
logger.debug("{} AppendEntryRequest of {} completed", name, log);
Timer.raftFollowerAppendEntryMS.addAndGet(System.nanoTime() - start);
- Timer.raftMemberAppendLogCounter.incrementAndGet();
+ Timer.raftFollowerAppendEntryCounter.incrementAndGet();
return result;
}