You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2018/09/04 20:46:44 UTC
[2/3] storm git commit: STORM-3208 add warning when no approved
workers to cleanup
STORM-3208 add warning when no approved workers to cleanup
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/26bfefb2
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/26bfefb2
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/26bfefb2
Branch: refs/heads/master
Commit: 26bfefb258282ab90b1577dd332c0d4e5cef87a8
Parents: 91458a3
Author: Aaron Gresch <ag...@yahoo-inc.com>
Authored: Thu Aug 30 11:36:12 2018 -0500
Committer: Aaron Gresch <ag...@yahoo-inc.com>
Committed: Thu Aug 30 11:36:12 2018 -0500
----------------------------------------------------------------------
.../java/org/apache/storm/daemon/supervisor/BasicContainer.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/26bfefb2/storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainer.java
----------------------------------------------------------------------
diff --git a/storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainer.java b/storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainer.java
index 082fc3b..9a6e526 100644
--- a/storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainer.java
+++ b/storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainer.java
@@ -218,6 +218,8 @@ public class BasicContainer extends Container {
removeWorkersOn(workersToPort, _port);
_localState.setApprovedWorkers(workersToPort);
LOG.info("Removed Worker ID {}", origWorkerId);
+ } else {
+ LOG.warn("No approved workers exists");
}
}
}