[kafka] branch trunk updated: MINOR: ConnectionStressWorker: add missing executor shutdown (#6558)

[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 04a023e  MINOR: ConnectionStressWorker: add missing executor shutdown 
(#6558)
04a023e is described below

commit 04a023e302d1c02c32bba1653303bc0d40140f18
Author: Colin Patrick McCabe <co...@cmccabe.xyz>
AuthorDate: Thu Apr 11 11:16:06 2019 -0700

    MINOR: ConnectionStressWorker: add missing executor shutdown (#6558)
---
 .../java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java
 
b/tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java
index e9bbf07..5c5db48 100644
--- 
a/tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java
+++ 
b/tools/src/main/java/org/apache/kafka/trogdor/workload/ConnectionStressWorker.java
@@ -309,6 +309,7 @@ public class ConnectionStressWorker implements TaskWorker {
         // Otherwise, if some threads take a while to terminate, this could 
lead
         // to a misleading rate getting reported.
         this.statusUpdaterFuture.cancel(false);
+        this.statusUpdaterExecutor.shutdown();
         this.statusUpdaterExecutor.awaitTermination(1, TimeUnit.DAYS);
         this.statusUpdaterExecutor = null;
         new StatusUpdater().run();