This is an automated email from the ASF dual-hosted git repository. srdo pushed a commit to branch 2.1.x-branch in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/2.1.x-branch by this push: new 4102e33 Revert "STORM-3476 don't query remote files on cleanup if target size is acceptable" 4102e33 is described below commit 4102e33930e32fa312842ae51ab3d98ed8becb77 Author: Stig Rohde Døssing <s...@apache.org> AuthorDate: Tue Aug 27 22:29:35 2019 +0200 Revert "STORM-3476 don't query remote files on cleanup if target size is acceptable" This reverts commit 1008feba371dd33232070603a54f8b3f4ed49ae7. --- .../org/apache/storm/localizer/LocalizedResourceRetentionSet.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/storm-server/src/main/java/org/apache/storm/localizer/LocalizedResourceRetentionSet.java b/storm-server/src/main/java/org/apache/storm/localizer/LocalizedResourceRetentionSet.java index 25d6f4d..f96b481 100644 --- a/storm-server/src/main/java/org/apache/storm/localizer/LocalizedResourceRetentionSet.java +++ b/storm-server/src/main/java/org/apache/storm/localizer/LocalizedResourceRetentionSet.java @@ -81,10 +81,6 @@ public class LocalizedResourceRetentionSet { public void cleanup(ClientBlobStore store) { LOG.debug("cleanup target size: {} current size is: {}", targetSize, currentSize); long bytesOver = currentSize - targetSize; - if (bytesOver <= 0) { // no need to query remote files - return; - } - //First delete everything that no longer exists... for (Iterator<Map.Entry<LocallyCachedBlob, Map<String, ? extends LocallyCachedBlob>>> i = noReferences.entrySet().iterator(); i.hasNext(); ) {