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 <[email protected]> Authored: Mon Nov 13 15:18:42 2017 -0600 Committer: Robert (Bobby) Evans <[email protected]> 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();
