diff options
Diffstat (limited to 'src/mongo/s/commands/cluster_aggregate.cpp')
| -rw-r--r-- | src/mongo/s/commands/cluster_aggregate.cpp | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/src/mongo/s/commands/cluster_aggregate.cpp b/src/mongo/s/commands/cluster_aggregate.cpp index 995ebd1a872..f2ba6b2b839 100644 --- a/src/mongo/s/commands/cluster_aggregate.cpp +++ b/src/mongo/s/commands/cluster_aggregate.cpp @@ -331,7 +331,6 @@ BSONObj establishMergingMongosCursor( params.mergePipeline = std::move(pipelineForMerging); params.remotes = std::move(cursors); - params.batchSize = request.getBatchSize(); auto ccc = ClusterClientCursorImpl::make( opCtx, Grid::get(opCtx)->getExecutorPool()->getArbitraryExecutor(), std::move(params)); @@ -341,8 +340,6 @@ BSONObj establishMergingMongosCursor( CursorResponseBuilder responseBuilder(true, &cursorResponse); - ccc->reattachToOperationContext(opCtx); - for (long long objCount = 0; objCount < request.getBatchSize(); ++objCount) { auto next = uassertStatusOK(ccc->next()); |