Repository: ignite Updated Branches: refs/heads/ignite-2004 c1b697f71 -> 126dc4b66
IGNITE-2004 Fixed review notes. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/126dc4b6 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/126dc4b6 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/126dc4b6 Branch: refs/heads/ignite-2004 Commit: 126dc4b66c6b797e392fa46e7a9d0af04c07f8a8 Parents: c1b697f Author: nikolay_tikhonov <[email protected]> Authored: Thu Apr 14 19:21:21 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Thu Apr 14 19:21:21 2016 +0300 ---------------------------------------------------------------------- .../query/continuous/CacheContinuousQueryHandler.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/126dc4b6/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 0f96a84..e086bdb 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 @@ -602,15 +602,15 @@ public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler entriesByPart.put(partId, new ArrayList<>(entries.subList(0, i))); } - Collection<CacheContinuousQueryEntry> ents = entriesByPart.get(curPart); + Collection<CacheContinuousQueryEntry> entries0 = entriesByPart.get(curPart); - if (ents == null) { - ents = new ArrayList<>(entries.size() - i); + if (entries0 == null) { + entries0 = new ArrayList<>(entries.size() - i); - entriesByPart.put(curPart, ents); + entriesByPart.put(curPart, entries0); } - ents.add(entries.get(i)); + entries0.add(entries.get(i)); } if (entriesByPart != null) {
