This is an automated email from the ASF dual-hosted git repository.
agresch pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/master by this push:
new 71023d2 STORM-3633 add message we're about to kill detached workers
new 3f96b79 Merge pull request #3266 from agresch/agresch_storm_3633
71023d2 is described below
commit 71023d2919ff67affe5d908fa2e8ecd0b526ca00
Author: Aaron Gresch <[email protected]>
AuthorDate: Tue May 12 09:50:28 2020 -0500
STORM-3633 add message we're about to kill detached workers
---
.../main/java/org/apache/storm/daemon/supervisor/ReadClusterState.java | 1 +
1 file changed, 1 insertion(+)
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 @@ public class ReadClusterState implements Runnable,
AutoCloseable {
}
}
if (!detachedRunningWorkers.isEmpty()) {
+ LOG.info("Killing detached workers {}",
detachedRunningWorkers);
supervisor.killWorkers(detachedRunningWorkers, launcher);
}
} catch (Exception e) {