oleg-vlsk commented on code in PR #11317:
URL: https://github.com/apache/ignite/pull/11317#discussion_r1581721203
##########
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryAdapter.java:
##########
@@ -579,21 +580,24 @@ private <R> CacheQueryFuture<R> execute0(@Nullable
IgniteReducer<T, R> rmtReduce
}
/** {@inheritDoc} */
- @Override public GridCloseableIterator executeScanQuery() throws
IgniteCheckedException {
- assert type == SCAN : "Wrong processing of query: " + type;
+ @Override public GridCloseableIterator executeQueryWithIterator() throws
IgniteCheckedException {
+ assert type == SCAN || type == INDEX : "Wrong processing of query: " +
type;
GridDhtCacheAdapter<?, ?> cacheAdapter = cctx.isNear() ?
cctx.near().dht() : cctx.dht();
Set<Integer> lostParts = cacheAdapter.topology().lostPartitions();
if (!lostParts.isEmpty()) {
if (part == null || lostParts.contains(part)) {
- throw new CacheException(new
CacheInvalidStateException("Failed to execute query because cache partition " +
Review Comment:
Done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
