STORM-4085 - Ensure that DownloadOrUpdate exception is caught (#3704)

Author: paxadax

storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java

@@ -197,7 +197,7 @@ private LocalizedResource getUserArchive(String user, String key) {
             throw new AssertionError("All user archives require a user present");
         }
         ConcurrentMap<String, LocalizedResource> keyToResource = userArchives.computeIfAbsent(user, (u) -> new ConcurrentHashMap<>());
-        return keyToResource.computeIfAbsent(key, 
+        return keyToResource.computeIfAbsent(key,
             (k) -> new LocalizedResource(key, localBaseDir, true, fsOps, conf, user, metricsRegistry));
     }
 
@@ -206,7 +206,7 @@ private LocalizedResource getUserFile(String user, String key) {
             throw new AssertionError("All user archives require a user present");
         }
         ConcurrentMap<String, LocalizedResource> keyToResource = userFiles.computeIfAbsent(user, (u) -> new ConcurrentHashMap<>());
-        return keyToResource.computeIfAbsent(key, 
+        return keyToResource.computeIfAbsent(key,
             (k) -> new LocalizedResource(key, localBaseDir, false, fsOps, conf, user, metricsRegistry));
     }
 
@@ -335,13 +335,11 @@ void updateBlobs() {
                 }
             }
             for (CompletableFuture<?> f : futures) {
-                try {
-                    f.get();
-                } catch (Exception e) {
-                    updateBlobExceptions.mark();
-                    LOG.warn("Could not update blob ({}), will retry again later." , e.getClass().getName());
-                }
+                f.get();
             }
+        } catch (Exception e) {
+            updateBlobExceptions.mark();
+            LOG.warn("Could not update blob ({}), will retry again later.", e.getClass().getName());
         }
     }