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 Thu, 25 May 2017 10:27:39 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-5075-cc 2c68adb8d -> 0305930e8


cc


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

Branch: refs/heads/ignite-5075-cc
Commit: 0305930e806d9394b5fe08af8a3be82048d46ca3
Parents: 2c68adb
Author: sboikov <sboikov@gridgain.com>
Authored: Thu May 25 13:23:03 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Thu May 25 13:23:03 2017 +0300

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


http://git-wip-us.apache.org/repos/asf/ignite/blob/0305930e/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 11ed922..98eaecb 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
@@ -891,6 +891,8 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler
 
         CacheContinuousQueryEventBuffer buf = partitionBuffer(cctx, e.partition());
 
+        e.markBackup();
+
         buf.processEntry(e.forBackupQueue(), true);
     }
 


Mime
View raw message