Merge branch 'STORM-2386-1.0.x' into 1.0.x-branch

apache · Mar 4, 2017 · 5423713 · 5423713
2 parents e91c03f + 932bf54
commit 5423713
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/storm-core/src/jvm/org/apache/storm/blobstore/BlobSynchronizer.java b/storm-core/src/jvm/org/apache/storm/blobstore/BlobSynchronizer.java
@@ -85,9 +85,7 @@ public synchronized void syncBlobs() {
                         BlobStoreUtils.createStateInZookeeper(conf, key, nimbusInfo);
                     }
                 } catch (KeyNotFoundException e) {
-                    LOG.debug("Detected deletion for the key {} - deleting the blob instead", key);
-                    // race condition with a delete, delete the blob in key instead
-                    blobStore.deleteBlob(key, BlobStoreUtils.getNimbusSubject());
+                    LOG.debug("Detected deletion for the key {} while downloading - skipping download", key);
                 }
             }
             if (zkClient !=null) {