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 c9e41b9 report
c9e41b9 is described below
commit c9e41b999233cae120f3044255829428316ee01a
Author: Ring-k <[email protected]>
AuthorDate: Tue Sep 1 15:18:06 2020 +0800
report
---
.../apache/iotdb/cluster/server/NodeReport.java | 1 +
.../org/apache/iotdb/cluster/server/Timer.java | 50 ++++++++++++++++++++++
2 files changed, 51 insertions(+)
diff --git
a/cluster/src/main/java/org/apache/iotdb/cluster/server/NodeReport.java
b/cluster/src/main/java/org/apache/iotdb/cluster/server/NodeReport.java
index ef41345..bb0b3cc 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/NodeReport.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/NodeReport.java
@@ -114,6 +114,7 @@ public class NodeReport {
", commitTerm=" + commitTerm +
", readOnly=" + isReadOnly +
", lastHeartbeat=" + (System.currentTimeMillis() -
lastHeartbeatReceivedTime) + "ms ago" +
+ ", \n timer: "+ Timer.getReport() +
'}';
}
}
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 c1c0a5d..c60cffb 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
@@ -18,4 +18,54 @@ public class Timer {
public static long raftMemberSendLogToFollowerCounter = 0L;
public static long raftMemberCommitLogMS = 0L;
public static long raftMemberCommitLogCounter = 0L;
+
+ private static final String dataGroupMemberProcessPlanLocallyMSString =
"Data group member - process plan locally : ";
+ private static final String dataGroupMemberWaitLeaderMSString = "Data group
member - wait leader: ";
+ private static final String metaGroupMemberExecuteNonQueryMSString = "Meta
group member - execute non query: ";
+ private static final String
metaGroupMemberExecuteNonQueryInLocalGroupMSString = "Meta group member -
execute in local group: ";
+ private static final String
metaGroupMemberExecuteNonQueryInRemoteGroupMSString = "Meta group member -
execute in remote group: ";
+ 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: ";
+
+ public static String getReport() {
+ String result = "";
+ result += dataGroupMemberProcessPlanLocallyMSString
+ + dataGroupMemberProcessPlanLocallyMS + ", "
+ + dataGroupMemberProcessPlanLocallyCounter + ", "
+ + (double) dataGroupMemberProcessPlanLocallyMS /
dataGroupMemberProcessPlanLocallyCounter
+ + "\n";
+ result += dataGroupMemberWaitLeaderMSString
+ + dataGroupMemberWaitLeaderMS + ", "
+ + dataGroupMemberWaitLeaderCounter + ", "
+ + (double) dataGroupMemberWaitLeaderMS /
dataGroupMemberWaitLeaderCounter + "\n";
+ result += metaGroupMemberExecuteNonQueryMSString
+ + metaGroupMemberExecuteNonQueryMS + ", "
+ + metaGroupMemberExecuteNonQueryCounter + ", "
+ + (double) metaGroupMemberExecuteNonQueryMS /
metaGroupMemberExecuteNonQueryCounter + "\n";
+ result += metaGroupMemberExecuteNonQueryInLocalGroupMSString
+ + metaGroupMemberExecuteNonQueryInLocalGroupMS + ", "
+ + metaGroupMemberExecuteNonQueryInLocalGroupCounter + ", "
+ + (double) metaGroupMemberExecuteNonQueryInLocalGroupMS
+ / metaGroupMemberExecuteNonQueryInLocalGroupCounter + "\n";
+ result += metaGroupMemberExecuteNonQueryInRemoteGroupMSString
+ + metaGroupMemberExecuteNonQueryInRemoteGroupMS + ", "
+ + metaGroupMemberExecuteNonQueryInRemoteGroupCounter + ", "
+ + (double) metaGroupMemberExecuteNonQueryInRemoteGroupMS
+ / metaGroupMemberExecuteNonQueryInRemoteGroupCounter + "\n";
+ result += raftMemberAppendLogMSString
+ + raftMemberAppendLogMS + ", "
+ + raftMemberAppendLogCounter + ", "
+ + (double) raftMemberAppendLogMS / raftMemberAppendLogCounter + "\n";
+ result += raftMemberSendLogToFollowerMSString
+ + raftMemberSendLogToFollowerMS + ", "
+ + raftMemberSendLogToFollowerCounter + ", "
+ + (double) raftMemberSendLogToFollowerMS /
raftMemberSendLogToFollowerCounter + "\n";
+ result += raftMemberCommitLogMSString
+ + raftMemberCommitLogMS + ", "
+ + raftMemberCommitLogCounter + ", "
+ + (double) raftMemberCommitLogMS / raftMemberCommitLogCounter + "\n";
+
+ return result;
+ }
}
