kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmcc...@apache.org
Subject [kafka] branch trunk updated: MINOR: ConnectionStressWorker: add missing executor shutdown (#6558)
Date Thu, 11 Apr 2019 18:16:20 GMT
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 <colin@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();


Mime
View raw message