Fixed GridCacheQueryRequest.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/039c48d3 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/039c48d3 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/039c48d3 Branch: refs/heads/ignite-264 Commit: 039c48d3fb1594deb9e1121afd06a7e107559f62 Parents: 1f6d2ff Author: sboikov <[email protected]> Authored: Fri Sep 4 11:33:34 2015 +0300 Committer: sboikov <[email protected]> Committed: Fri Sep 4 11:33:34 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/cache/query/GridCacheQueryRequest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/039c48d3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java index f7ef76f..c9ce933 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryRequest.java @@ -262,7 +262,7 @@ public class GridCacheQueryRequest extends GridCacheMessage implements GridCache /** {@inheritDoc} */ @Override public AffinityTopologyVersion topologyVersion() { - return topVer; + return topVer != null ? topVer : AffinityTopologyVersion.NONE; } /** {@inheritDoc} */
