Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2710#discussion_r208279468
--- Diff:
storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java ---
@@ -251,11 +261,18 @@ private LocalizedResource getUserFile(String user,
String key) {
long localVersion = blob.getLocalVersion();
long remoteVersion =
blob.getRemoteVersion(blobStore);
if (localVersion != remoteVersion ||
!blob.isFullyDownloaded()) {
+ if (!blob.isFullyDownloaded()) {
--- End diff --
Should be `if (!blob.isFullyDownloaded()) {`
---
