Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2812#discussion_r213030742
--- 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 there are multiple supervisors running on a single host they all have to
have different directories or a lot of really bad stuff will happen all
throughout the code base.
---
