[incubator-iotdb] branch cluster_performance updated: remove histo

[yuyuankang]

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 0b19c04  remove histo
0b19c04 is described below

commit 0b19c04f06d1a8ac76d98ea14322088227b98097
Author: Ring-k <yuyuank...@hotmail.com>
AuthorDate: Tue Sep 8 17:25:38 2020 +0800

    remove histo
---
 .../src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java | 5 ++---
 cluster/src/main/java/org/apache/iotdb/cluster/server/Timer.java  | 8 ++++----
 2 files changed, 6 insertions(+), 7 deletions(-)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java 
b/cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
index db338ec..a57a332 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/log/LogDispatcher.java
@@ -19,7 +19,6 @@
 
 package org.apache.iotdb.cluster.log;
 
-import static org.apache.iotdb.cluster.server.Timer.currentBatchHisto;
 
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
@@ -77,7 +76,7 @@ public class LogDispatcher {
   public void offer(SendLogRequest log) {
     for (BlockingQueue<SendLogRequest> nodeLogQueue : nodeLogQueues) {
       nodeLogQueue.offer(log);
-      Timer.queueHisto[nodeLogQueue.size()]++;
+//      Timer.queueHisto[nodeLogQueue.size()]++;
       log.enqueueTime = System.nanoTime();
     }
     if (logger.isDebugEnabled()) {
@@ -142,7 +141,7 @@ public class LogDispatcher {
           if (logger.isDebugEnabled()) {
             logger.debug("Sending {} logs to {}", currBatch.size(), receiver);
           }
-          Timer.currentBatchHisto[currBatch.size()]++;
+//          Timer.currentBatchHisto[currBatch.size()]++;
 
           List<ByteBuffer> logList = new ArrayList<>();;
           for (SendLogRequest request : currBatch) {
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 5329ff2..89175dd 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
@@ -49,8 +49,8 @@ public class Timer {
   public static Statistic raftMemberFromCreateToAppendLog = new 
Statistic("Raft member - from create to append log: ", 1000000L);
   public static Statistic logDispatcherFromCreateToEnd= new Statistic("Log 
dispatcher - from create to end: ", 1000000L);
 
-  public static int[] queueHisto = new int[180];
-  public static int[] currentBatchHisto = new int[180];
+//  public static int[] queueHisto = new int[180];
+//  public static int[] currentBatchHisto = new int[180];
 
   static Statistic[] statistics = new 
Statistic[]{dataGroupMemberProcessPlanLocally,
       dataGroupMemberWaitLeader,
@@ -108,8 +108,8 @@ public class Timer {
     for (Statistic s : statistics) {
       result += s.toString() + "\n";
     }
-    result += Arrays.toString(queueHisto) + "\n";
-    result += Arrays.toString(currentBatchHisto) + "\n";
+//    result += Arrays.toString(queueHisto) + "\n";
+//    result += Arrays.toString(currentBatchHisto) + "\n";
     return result;
   }
 }