[kafka] branch trunk updated: MINOR - Increase the number of Trogdor Histogram buckets to 10000 (#8627)

[cmccabe]

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

cmccabe pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 5203ab0  MINOR - Increase the number of Trogdor Histogram buckets to 
10000 (#8627)
5203ab0 is described below

commit 5203ab0c5d71d7fad16a308c7b2706dc80b4255e
Author: Scott Hendricks <49452084+scott-hendri...@users.noreply.github.com>
AuthorDate: Thu May 7 00:10:19 2020 -0400

    MINOR - Increase the number of Trogdor Histogram buckets to 10000 (#8627)
    
    Reviewers: Colin P. McCabe <cmcc...@apache.org>
---
 .../main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java | 2 +-
 .../main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java 
b/tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java
index a397f84..4e77dff 100644
--- 
a/tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java
+++ 
b/tools/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java
@@ -200,7 +200,7 @@ public class ConsumeBenchWorker implements TaskWorker {
         private final ThreadSafeConsumer consumer;
 
         private ConsumeMessages(ThreadSafeConsumer consumer) {
-            this.latencyHistogram = new Histogram(5000);
+            this.latencyHistogram = new Histogram(10000);
             this.messageSizeHistogram = new Histogram(2 * 1024 * 1024);
             this.clientId = consumer.clientId();
             this.statusUpdaterFuture = executor.scheduleAtFixedRate(
diff --git 
a/tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java 
b/tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java
index 770a174..4b262ef 100644
--- 
a/tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java
+++ 
b/tools/src/main/java/org/apache/kafka/trogdor/workload/ProduceBenchWorker.java
@@ -195,7 +195,7 @@ public class ProduceBenchWorker implements TaskWorker {
         SendRecords(HashSet<TopicPartition> activePartitions) {
             this.activePartitions = activePartitions;
             this.partitionsIterator = activePartitions.iterator();
-            this.histogram = new Histogram(5000);
+            this.histogram = new Histogram(10000);
 
             this.transactionGenerator = spec.transactionGenerator();
             this.enableTransactions = this.transactionGenerator.isPresent();