ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: cc
Date Wed, 24 May 2017 17:14:08 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-5075-cc c2c9277be -> 79e34c2cf


cc


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

Branch: refs/heads/ignite-5075-cc
Commit: 79e34c2cfdd28e0df479bb96ba8b667b30566463
Parents: c2c9277
Author: sboikov <sboikov@gridgain.com>
Authored: Wed May 24 20:12:00 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed May 24 20:12:00 2017 +0300

----------------------------------------------------------------------
 .../cache/query/continuous/CacheContinuousQueryHandler.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/79e34c2c/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 c046095..f7547f5 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
@@ -1156,7 +1156,7 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler
                         boolean fire = e.getKey() == lastFiredEvt + 1;;
 
                         if (!fire && filtered > 0)
-                            fire = e.getKey() - filtered == lastFiredEvt + 1;
+                            fire = e.getKey() - filtered <= lastFiredEvt + 1;
 
                         if (fire) {
                             lastFiredEvt = e.getKey();


Mime
View raw message