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-debug Commit: 0305930e806d9394b5fe08af8a3be82048d46ca3 Parents: 2c68adb Author: sboikov <[email protected]> Authored: Thu May 25 13:23:03 2017 +0300 Committer: sboikov <[email protected]> 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); }
