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 2017/11/14 21:54:08 UTC
[1/2] storm git commit: STORM-2809: Always create the resources
directory so we can check for it
Repository: storm
Updated Branches:
refs/heads/master 6a26bef8f -> a1ef0f616
STORM-2809: Always create the resources directory so we can check for it
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6bc873cd
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6bc873cd
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6bc873cd
Branch: refs/heads/master
Commit: 6bc873cd23ecc4d20758afca322f44f6a3713e8c
Parents: 2709a1c
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Mon Nov 13 15:18:42 2017 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Mon Nov 13 15:18:42 2017 -0600
----------------------------------------------------------------------
.../org/apache/storm/localizer/LocallyCachedTopologyBlob.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/6bc873cd/storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java
----------------------------------------------------------------------
diff --git a/storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java b/storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java
index 68415e1..1521a96 100644
--- a/storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java
+++ b/storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java
@@ -217,6 +217,10 @@ public class LocallyCachedTopologyBlob extends LocallyCachedBlob {
protected void extractDirFromJar(String jarpath, String dir, Path dest) throws IOException {
LOG.debug("EXTRACTING {} from {} and placing it at {}", dir, jarpath, dest);
+ if (!Files.exists(dest)) {
+ //Create the directory no matter what. This is so we can check if it was downloaded in the future.
+ Files.createDirectories(dest);
+ }
try (JarFile jarFile = new JarFile(jarpath)) {
String toRemove = dir + '/';
Enumeration<JarEntry> jarEnums = jarFile.entries();
[2/2] storm git commit: Merge branch 'STORM-2809' of
https://github.com/revans2/incubator-storm into asfgit-master
Posted by sr...@apache.org.
Merge branch 'STORM-2809' of https://github.com/revans2/incubator-storm into asfgit-master
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a1ef0f61
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a1ef0f61
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a1ef0f61
Branch: refs/heads/master
Commit: a1ef0f6169761721a1c6f9247fdaf8544c2f3d8d
Parents: 6a26bef 6bc873c
Author: Stig Rohde Døssing <sr...@apache.org>
Authored: Tue Nov 14 22:52:41 2017 +0100
Committer: Stig Rohde Døssing <sr...@apache.org>
Committed: Tue Nov 14 22:52:41 2017 +0100
----------------------------------------------------------------------
.../org/apache/storm/localizer/LocallyCachedTopologyBlob.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------