Repository: apex-malhar Updated Branches: refs/heads/master f0a70fbbb -> f4fb62c49
APEXMALHAR-2362 #resolve clearing the removedSets at endWindow in SpillableSetMultimapImpl Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/87e4cbdd Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/87e4cbdd Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/87e4cbdd Branch: refs/heads/master Commit: 87e4cbddaf82c72d6a6b08bbda3b33b25fb01765 Parents: 243dceb Author: David Yan <[email protected]> Authored: Wed Nov 30 15:18:46 2016 -0800 Committer: David Yan <[email protected]> Committed: Wed Nov 30 15:18:46 2016 -0800 ---------------------------------------------------------------------- .../apex/malhar/lib/state/spillable/SpillableSetMultimapImpl.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/87e4cbdd/library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableSetMultimapImpl.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableSetMultimapImpl.java b/library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableSetMultimapImpl.java index fb88d9c..24cc8b2 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableSetMultimapImpl.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/state/spillable/SpillableSetMultimapImpl.java @@ -372,6 +372,7 @@ public class SpillableSetMultimapImpl<K, V> implements Spillable.SpillableSetMul for (SpillableSetImpl removedSet : removedSets) { removedSet.endWindow(); } + removedSets.clear(); cache.endWindow(); map.endWindow();
