You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by br...@apache.org on 2016/12/06 23:36:44 UTC
[1/2] apex-malhar git commit: APEXMALHAR-2362 #resolve clearing the
removedSets at endWindow in SpillableSetMultimapImpl
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 <da...@datatorrent.com>
Authored: Wed Nov 30 15:18:46 2016 -0800
Committer: David Yan <da...@datatorrent.com>
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();
[2/2] apex-malhar git commit: Merge commit 'refs/pull/519/head' of
github.com:apache/apex-malhar
Posted by br...@apache.org.
Merge commit 'refs/pull/519/head' of github.com:apache/apex-malhar
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/f4fb62c4
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/f4fb62c4
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/f4fb62c4
Branch: refs/heads/master
Commit: f4fb62c49dadbb744b5b16eb5b7a9441bb3828e3
Parents: f0a70fb 87e4cbd
Author: brightchen <br...@datatorrent.com>
Authored: Tue Dec 6 15:35:23 2016 -0800
Committer: brightchen <br...@datatorrent.com>
Committed: Tue Dec 6 15:35:23 2016 -0800
----------------------------------------------------------------------
.../apex/malhar/lib/state/spillable/SpillableSetMultimapImpl.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------