Github user danny0405 commented on a diff in the pull request: https://github.com/apache/storm/pull/2812#discussion_r212851256 --- Diff: storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java --- @@ -125,6 +129,12 @@ public long getRemoteVersion(ClientBlobStore store) throws KeyNotFoundException, @Override public long fetchUnzipToTemp(ClientBlobStore store) throws IOException, KeyNotFoundException, AuthorizationException { + synchronized (LocallyCachedTopologyBlob.class) { + if (!Files.exists(topologyBasicBlobsRootDir)) { --- End diff -- If we enforce different dirs for supervisors on one machine, i'm okey with this.ð
---