You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2018/10/01 21:49:04 UTC
[9/9] ignite git commit: GG-14206
GG-14206
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/17f01789
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/17f01789
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/17f01789
Branch: refs/heads/ignite-gg-14206
Commit: 17f017896ccab1b8246230b0f849d609f2e219d8
Parents: 96c271b
Author: sboikov <sb...@apache.org>
Authored: Tue Oct 2 00:47:18 2018 +0300
Committer: sboikov <sb...@apache.org>
Committed: Tue Oct 2 00:47:18 2018 +0300
----------------------------------------------------------------------
.../cache/query/continuous/CacheContinuousQueryManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/17f01789/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
index ab60f47..aa276cc 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
@@ -395,7 +395,7 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter {
cctx.cacheId(),
evtType,
key,
- evtType == REMOVED && lsnr.oldValueRequired() ? oldVal : newVal,
+ (!internal && evtType == REMOVED && lsnr.oldValueRequired()) ? oldVal : newVal,
lsnr.oldValueRequired() ? oldVal : null,
lsnr.keepBinary(),
partId,