You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2018/06/17 16:18:41 UTC
storm git commit: STORM-3109: Fixed incorrect conversion from
relative path to absolute path for STORM_LOCAL_DIR
Repository: storm
Updated Branches:
refs/heads/1.x-branch b0f34ac1b -> 8fabff553
STORM-3109: Fixed incorrect conversion from relative path to absolute path for STORM_LOCAL_DIR
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8fabff55
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8fabff55
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8fabff55
Branch: refs/heads/1.x-branch
Commit: 8fabff55325d68c79470b65f33176f95007062af
Parents: b0f34ac
Author: Zhengdai Hu <zh...@oath.com>
Authored: Fri Jun 15 16:56:01 2018 -0500
Committer: Stig Rohde Døssing <sr...@apache.org>
Committed: Sun Jun 17 18:16:55 2018 +0200
----------------------------------------------------------------------
storm-core/src/jvm/org/apache/storm/command/KillWorkers.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8fabff55/storm-core/src/jvm/org/apache/storm/command/KillWorkers.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/command/KillWorkers.java b/storm-core/src/jvm/org/apache/storm/command/KillWorkers.java
index b9f8c14..9b547e1 100644
--- a/storm-core/src/jvm/org/apache/storm/command/KillWorkers.java
+++ b/storm-core/src/jvm/org/apache/storm/command/KillWorkers.java
@@ -26,9 +26,8 @@ import org.apache.storm.daemon.supervisor.Supervisor;
import org.apache.storm.utils.ConfigUtils;
public class KillWorkers {
- public static void main(String [] args) throws Exception {
+ public static void main(String[] args) throws Exception {
Map<String, Object> conf = ConfigUtils.readStormConfig();
- conf.put(Config.STORM_LOCAL_DIR, new File((String)conf.get(Config.STORM_LOCAL_DIR)).getCanonicalPath());
try (Supervisor supervisor = new Supervisor(conf, null, new StandaloneSupervisor())) {
supervisor.shutdownAllWorkers(null, null);
}