commit 3f96b79d57b56b25cd93ee49d85c09e78bb674b3
author agresch <agresch@gmail.com> Wed May 13 09:44:45 2020 -0500
committer GitHub <noreply@github.com> Wed May 13 09:44:45 2020 -0500
tree 0449501319f405b7f31efe167d6e2bba755fd943
parent 250fe114023fa120df7f94d7d954930aba6de7a4
parent 71023d2919ff67affe5d908fa2e8ecd0b526ca00

Merge pull request #3266 from agresch/agresch_storm_3633

STORM-3633 add message we're about to kill detached workers

storm-server/src/main/java/org/apache/storm/daemon/supervisor/ReadClusterState.java

diff --git a/storm-server/src/main/java/org/apache/storm/daemon/supervisor/ReadClusterState.java b/storm-server/src/main/java/org/apache/storm/daemon/supervisor/ReadClusterState.java
index 503b44a..35d0857 100644
--- a/storm-server/src/main/java/org/apache/storm/daemon/supervisor/ReadClusterState.java
+++ b/storm-server/src/main/java/org/apache/storm/daemon/supervisor/ReadClusterState.java
@@ -113,6 +113,7 @@
                 }
             }
             if (!detachedRunningWorkers.isEmpty()) {
+                LOG.info("Killing detached workers {}", detachedRunningWorkers);
                 supervisor.killWorkers(detachedRunningWorkers, launcher);
             }
         } catch (Exception e) {