From c1dcc9ce46f53dd89b80a08d363d5eacac1b9e23 Mon Sep 17 00:00:00 2001 From: nitsanw Date: Wed, 6 Jul 2016 14:45:18 +0200 Subject: [PATCH] Fix hdr logging for single operation workloads Patch by Nitsan Wakart; reviewed by tjake for CASSANDRA-12145 --- CHANGES.txt | 1 + .../org/apache/cassandra/stress/StressMetrics.java | 13 ++++++++----- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/CHANGES.txt b/CHANGES.txt index 34e75870e1..b094b00cb5 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 3.9 + * Fix hdr logging for single operation workloads (CASSANDRA-12145) * Fix SASI PREFIX search in CONTAINS mode with partial terms (CASSANDRA-12073) * Increase size of flushExecutor thread pool (CASSANDRA-12071) Merged from 3.0: diff --git a/tools/stress/src/org/apache/cassandra/stress/StressMetrics.java b/tools/stress/src/org/apache/cassandra/stress/StressMetrics.java index 668518c52a..86e9a7af4b 100644 --- a/tools/stress/src/org/apache/cassandra/stress/StressMetrics.java +++ b/tools/stress/src/org/apache/cassandra/stress/StressMetrics.java @@ -191,15 +191,18 @@ public class StressMetrics rowRateUncertainty.update(current.adjustedRowRate()); if (current.operationCount() != 0) { - if (result.intervals.intervals().size() > 1) + // if there's a single operation we only print the total + final boolean logPerOpSummaryLine = result.intervals.intervals().size() > 1; + + for (Map.Entry type : result.intervals.intervals().entrySet()) { - for (Map.Entry type : result.intervals.intervals().entrySet()) + final String opName = type.getKey(); + final TimingInterval opInterval = type.getValue(); + if (logPerOpSummaryLine) { - final String opName = type.getKey(); - final TimingInterval opInterval = type.getValue(); printRow("", opName, opInterval, timing.getHistory().get(type.getKey()), result.extra, rowRateUncertainty, output); - logHistograms(opName, opInterval); } + logHistograms(opName, opInterval); } printRow("", "total", current, history, result.extra, rowRateUncertainty, output);