You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2018/06/26 07:48:27 UTC
[1/2] storm git commit: MINOR: Mkdir for storm.home when running
LocalCluster
Repository: storm
Updated Branches:
refs/heads/master 21bb13884 -> a050ee8b1
MINOR: Mkdir for storm.home when running LocalCluster
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3a66a47b
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3a66a47b
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3a66a47b
Branch: refs/heads/master
Commit: 3a66a47b45de82260ed6731f5af469da11165690
Parents: d6f8afb
Author: Stig Rohde Døssing <sr...@apache.org>
Authored: Sun Jun 24 22:57:38 2018 +0200
Committer: Stig Rohde Døssing <sr...@apache.org>
Committed: Sun Jun 24 22:57:38 2018 +0200
----------------------------------------------------------------------
storm-server/src/main/java/org/apache/storm/LocalCluster.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/3a66a47b/storm-server/src/main/java/org/apache/storm/LocalCluster.java
----------------------------------------------------------------------
diff --git a/storm-server/src/main/java/org/apache/storm/LocalCluster.java b/storm-server/src/main/java/org/apache/storm/LocalCluster.java
index 15679a8..5332b5e 100644
--- a/storm-server/src/main/java/org/apache/storm/LocalCluster.java
+++ b/storm-server/src/main/java/org/apache/storm/LocalCluster.java
@@ -196,8 +196,11 @@ public class LocalCluster implements ILocalClusterTrackedTopologyAware, Iface {
this.tmpDirs.add(nimbusTmp);
stormHomeBackup = System.getProperty(ConfigUtils.STORM_HOME);
TmpPath stormHome = new TmpPath();
+ if (!stormHome.getFile().mkdirs()) {
+ throw new IllegalStateException("Failed to create storm.home directory " + stormHome.getPath());
+ }
this.tmpDirs.add(stormHome);
- System.setProperty(ConfigUtils.STORM_HOME, stormHome.getPath());
+ System.setProperty(ConfigUtils.STORM_HOME, stormHome.getPath());
Map<String, Object> conf = ConfigUtils.readStormConfig();
conf.put(Config.TOPOLOGY_SKIP_MISSING_KRYO_REGISTRATIONS, true);
conf.put(Config.TOPOLOGY_ENABLE_MESSAGE_TIMEOUTS, false);
[2/2] storm git commit: Merge branch 'mkdir-storm-local' of
https://github.com/srdo/storm into mkdir-storm-local-merge
Posted by ka...@apache.org.
Merge branch 'mkdir-storm-local' of https://github.com/srdo/storm into mkdir-storm-local-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a050ee8b
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a050ee8b
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a050ee8b
Branch: refs/heads/master
Commit: a050ee8b1987c3fc37a7ee7be4231b108c779aa4
Parents: 21bb138 3a66a47
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Tue Jun 26 16:48:16 2018 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Tue Jun 26 16:48:16 2018 +0900
----------------------------------------------------------------------
storm-server/src/main/java/org/apache/storm/LocalCluster.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------