Fixed executor shutdown exception when running multiple workloads

merlimat · merlimat · commit f8cb005f7cce · 2018-01-16T10:54:39.000-08:00
diff --git a/benchmark-framework/src/main/java/io/openmessaging/benchmark/WorkloadGenerator.java b/benchmark-framework/src/main/java/io/openmessaging/benchmark/WorkloadGenerator.java
@@ -54,7 +54,7 @@ public class WorkloadGenerator implements ConsumerCallback, AutoCloseable {
     private final BenchmarkDriver benchmarkDriver;
     private final Workload workload;
 
-    private static final ExecutorService executor = Executors
+    private final ExecutorService executor = Executors
             .newCachedThreadPool(new DefaultThreadFactory("messaging-benchmark"));
 
     private final LongAdder messagesSent = new LongAdder();
