You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2019/10/22 14:11:07 UTC
[ignite] 01/02: Minors
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a commit to branch ignite-12189
in repository https://gitbox.apache.org/repos/asf/ignite.git
commit b2d1b7a4ba1770859bcd5f987c71b4f4e10acfa7
Author: Andrey V. Mashenkov <an...@gmail.com>
AuthorDate: Tue Oct 22 16:33:50 2019 +0300
Minors
---
.../internal/processors/cache/query/GridCacheQueryFutureAdapter.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryFutureAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryFutureAdapter.java
index c79b3eb..28ab99a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryFutureAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryFutureAdapter.java
@@ -105,6 +105,7 @@ public abstract class GridCacheQueryFutureAdapter<K, V, R> extends GridFutureAda
protected GridCacheQueryFutureAdapter() {
qry = null;
keys = null;
+ capacity = NO_LIMIT;
}
/**
@@ -122,7 +123,7 @@ public abstract class GridCacheQueryFutureAdapter<K, V, R> extends GridFutureAda
startTime = U.currentTimeMillis();
- final int limit = query().query().limit();
+ final int limit = qry.query().limit();
capacity = limit > 0 ? limit : NO_LIMIT;