Github user danny0405 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2618#discussion_r178693115
--- Diff:
storm-server/src/main/java/org/apache/storm/localizer/LocalizedResourceRetentionSet.java
---
@@ -94,17 +93,17 @@ public void cleanup(ClientBlobStore store) {
Map.Entry<LocallyCachedBlob, Map<String, ? extends
LocallyCachedBlob>> rsrc = i.next();
LocallyCachedBlob resource = rsrc.getKey();
try {
- resource.getRemoteVersion(store);
+ if (!store.isRemoteBlobExists(resource.getKey())) {
--- End diff --
Ok, i will separate it apart with another JIRA.
---
