Adding option to skip aggregate output timing metrics

src/main/java/com/emc/mongoose/base/load/step/client/LoadStepClientBase.java

@@ -215,9 +215,11 @@ extensions, storageConfig, dataInput, verifyFlag, batchSize, loadStepId()
 			Loggers.MSG.debug("{}: item output file aggregator initialized", loadStepId());
 		}
 
-		itemTimingMetricsOutputFileAggregators.add(
+		if (!config.boolVal("output-metrics-skip-timing")) {
+			itemTimingMetricsOutputFileAggregators.add(
 				new ItemTimingMetricOutputFileAggregator(loadStepId(), fileMgrs));
-		Loggers.MSG.debug("{}: item metrics output file aggregator initialized", loadStepId());
+			Loggers.MSG.debug("{}: item metrics output file aggregator initialized", loadStepId());
+		}
 
 		if(config.boolVal("output-metrics-trace-persist")) {
 			opTraceLogFileAggregators.add(new OpTraceLogFileAggregator(loadStepId(), fileMgrs));

src/main/java/com/emc/mongoose/base/metrics/snapshot/TimingMetricQuantileResultsImpl.java

@@ -16,6 +16,7 @@
 import java.nio.file.FileSystemException;
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.HashMap;
 import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
@@ -70,16 +71,17 @@ public TimingMetricQuantileResultsImpl(final List<Double> quantileValues, final
                 })
                 .collect(Collectors.toList());
         if (tmpMetrics.size() != nodeAmount) {
+            metricsValues = new HashMap<>(); // No metrics
             Loggers.ERR.warn(
                     "Expected to aggregate timing metrics from {} node(s), but found {} local file(s) after aggregation for pattern {}",
                     nodeAmount, tmpMetrics.size(), metricsFilePattern);
+        } else {
+            // merge sorted metrics arrays from each aggregated local tmp file and take the quantile values from it
+            // we do not want to store the whole values list in the class as we can eventually reach a few Gb size array of
+            // latency/duration values.
+            // So we only store a few values of specified quantiles
+            metricsValues = retrieveQuantileValues(quantileValues, mergeSort(tmpMetrics));
         }
-
-        // merge sorted metrics arrays from each aggregated local tmp file and take the quantile values from it
-        // we do not want to store the whole values list in the class as we can eventually reach a few Gb size array of
-        // latency/duration values.
-        // So we only store a few values of specified quantiles
-        metricsValues = retrieveQuantileValues(quantileValues, mergeSort(tmpMetrics));
     }
 
     private File[] findAllWorkersMetricsFiles() {

src/main/resources/config-schema.yaml

@@ -80,6 +80,8 @@ output:
       persist: boolean
     threshold: double
     quantiles: list
+    skip:
+      timing: boolean
 run:
   id: long
   comment: string

src/main/resources/config/defaults.yaml

@@ -85,6 +85,8 @@ output:
     - 0.25
     - 0.5
     - 0.75
+    skip:
+      timing: false
 
 run:
   id: 0