Repository: ignite Updated Branches: refs/heads/ignite-5075-cc 83083534e -> 8f4eba119
cc Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8f4eba11 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8f4eba11 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8f4eba11 Branch: refs/heads/ignite-5075-cc Commit: 8f4eba119d8c90796fb4fb18acef334cb3e9c44c Parents: 8308353 Author: sboikov <[email protected]> Authored: Wed May 24 15:22:34 2017 +0300 Committer: sboikov <[email protected]> Committed: Wed May 24 15:22:34 2017 +0300 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryHandler.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/8f4eba11/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java index 18faff4..c046095 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java @@ -1153,13 +1153,13 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler long filtered = pending.filteredCount(); - boolean fire = entry.updateCounter() == lastFiredEvt + 1;; + boolean fire = e.getKey() == lastFiredEvt + 1;; if (!fire && filtered > 0) - fire = entry.updateCounter() - filtered == lastFiredEvt + 1; + fire = e.getKey() - filtered == lastFiredEvt + 1; if (fire) { - lastFiredEvt = entry.updateCounter(); + lastFiredEvt = e.getKey(); if (e.getValue() != HOLE && !e.getValue().isFiltered()) entries.add(new CacheContinuousQueryEvent<K, V>(cache, cctx, e.getValue()));
