cc
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e6ffd828 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e6ffd828 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e6ffd828 Branch: refs/heads/ignite-5075-cc-debug Commit: e6ffd828828ddc2aba00140742cb0cf30038b520 Parents: 0305930 Author: sboikov <[email protected]> Authored: Thu May 25 13:32:03 2017 +0300 Committer: sboikov <[email protected]> Committed: Thu May 25 13:32:03 2017 +0300 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryHandler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/e6ffd828/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 98eaecb..b4f2dbd 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 @@ -456,6 +456,8 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler if (backupQueue != null && node != null) { for (CacheContinuousQueryEntry e : backupQueue) { + e.markBackup(); + if (!e.isFiltered()) prepareEntry(cctx, nodeId, e); } @@ -891,8 +893,6 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler CacheContinuousQueryEventBuffer buf = partitionBuffer(cctx, e.partition()); - e.markBackup(); - buf.processEntry(e.forBackupQueue(), true); }
