Skip to content

Commit 91521a6

Browse files
authored
IGNITE-22216 Remove unused check for allPages in GridCacheQueryManager#runAll (#11356)
1 parent 1c469b0 commit 91521a6

File tree

1 file changed

+1
-12
lines changed

1 file changed

+1
-12
lines changed

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/GridCacheQueryManager.java

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1162,13 +1162,10 @@ protected void runQuery(GridCacheQueryInfo qryInfo) {
11621162

11631163
int cnt = 0;
11641164

1165-
boolean stop = false;
11661165
boolean pageSent = false;
11671166

11681167
Collection<Object> data = new ArrayList<>(pageSize);
11691168

1170-
AffinityTopologyVersion topVer = cctx.affinity().affinityTopologyVersion();
1171-
11721169
final boolean statsEnabled = cctx.statisticsEnabled();
11731170

11741171
final boolean readEvt = cctx.events().isRecordable(EVT_CACHE_QUERY_OBJECT_READ);
@@ -1289,20 +1286,12 @@ protected void runQuery(GridCacheQueryInfo qryInfo) {
12891286

12901287
onPageReady(loc, qryInfo, res.metadata(), data, finished, null);
12911288

1292-
pageSent = true;
1293-
12941289
res.onPageSend();
12951290

12961291
if (!finished)
12971292
rmvIter = false;
12981293

1299-
if (!qryInfo.allPages())
1300-
return;
1301-
1302-
data = new ArrayList<>(pageSize);
1303-
1304-
if (stop)
1305-
break; // while
1294+
return;
13061295
}
13071296
}
13081297
}

0 commit comments

Comments
 (0)