cc

Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b6d93848
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b6d93848
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b6d93848

Branch: refs/heads/ignite-5075-cc
Commit: b6d938482e6fb3f3ca1bcefd0f3508ebd4fd3a6c
Parents: edc8eb1
Author: sboikov <[email protected]>
Authored: Mon May 29 12:30:05 2017 +0300
Committer: sboikov <[email protected]>
Committed: Mon May 29 12:30:05 2017 +0300

----------------------------------------------------------------------
 .../cache/query/continuous/CacheContinuousQueryEntry.java         | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/b6d93848/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
index 3f463a1..d1af1b1 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
@@ -209,6 +209,9 @@ public class CacheContinuousQueryEntry implements 
GridCacheDeployable, Message {
      */
     void markFiltered() {
         flags |= FILTERED_ENTRY;
+        key = null;
+        newVal = null;
+        oldVal = null;
         depInfo = null;
     }
 

Reply via email to