Repository: storm Updated Branches: refs/heads/master 4ca7522d1 -> 7562da30b
Address comments. Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1c974b8f Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1c974b8f Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1c974b8f Branch: refs/heads/master Commit: 1c974b8f325e5843e1303f423c3d6c0a6e0d4bd9 Parents: 02349ac Author: zhuol <[email protected]> Authored: Thu Feb 18 20:54:30 2016 -0600 Committer: zhuol <[email protected]> Committed: Fri Feb 19 13:04:35 2016 -0600 ---------------------------------------------------------------------- storm-core/src/jvm/org/apache/storm/ProcessSimulator.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/1c974b8f/storm-core/src/jvm/org/apache/storm/ProcessSimulator.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/ProcessSimulator.java b/storm-core/src/jvm/org/apache/storm/ProcessSimulator.java index bcc46b8..10d737d 100644 --- a/storm-core/src/jvm/org/apache/storm/ProcessSimulator.java +++ b/storm-core/src/jvm/org/apache/storm/ProcessSimulator.java @@ -25,6 +25,10 @@ import java.util.concurrent.ConcurrentHashMap; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/** + * In local mode, {@code ProcessSimulator} keeps track of Shutdownable objects + * in place of actual processes (in cluster mode). + */ public class ProcessSimulator { private static Logger LOG = LoggerFactory.getLogger(ProcessSimulator.class); private static Object lock = new Object(); @@ -70,11 +74,9 @@ public class ProcessSimulator { * kill all processes */ public static void killAllProcesses() { - LOG.info("Begin killing all processes"); Set<String> pids = processMap.keySet(); for (String pid : pids) { killProcess(pid); } - LOG.info("Successfully killed all processes"); } }
