summaryrefslogtreecommitdiff
path: root/src/mongo/s/query/cluster_aggregation_planner.cpp
diff options
context:
space:
mode:
authorDenis Grebennicov <denis.grebennicov@mongodb.com>2021-07-05 18:23:41 +0200
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-07-12 09:12:25 +0000
commit77fb77fb8ef0139558787cb59d563bb75d3d94e1 (patch)
treec2e2fb9a56fe1131f6ae4d97ca203a688a1ac4d9 /src/mongo/s/query/cluster_aggregation_planner.cpp
parent5769969b746c079fa9cd6fd52a11a25b6a5df417 (diff)
downloadmongo-77fb77fb8ef0139558787cb59d563bb75d3d94e1.tar.gz
SERVER-57985 Remove RouterExecStage::ExecContext
Diffstat (limited to 'src/mongo/s/query/cluster_aggregation_planner.cpp')
-rw-r--r--src/mongo/s/query/cluster_aggregation_planner.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/mongo/s/query/cluster_aggregation_planner.cpp b/src/mongo/s/query/cluster_aggregation_planner.cpp
index f2913fad553..855d11db881 100644
--- a/src/mongo/s/query/cluster_aggregation_planner.cpp
+++ b/src/mongo/s/query/cluster_aggregation_planner.cpp
@@ -284,7 +284,7 @@ BSONObj establishMergingMongosCursor(OperationContext* opCtx,
for (long long objCount = 0; objCount < batchSize; ++objCount) {
ClusterQueryResult next;
try {
- next = uassertStatusOK(ccc->next(RouterExecStage::ExecContext::kInitialFind));
+ next = uassertStatusOK(ccc->next());
} catch (const ExceptionFor<ErrorCodes::CloseChangeStream>&) {
// This exception is thrown when a $changeStream stage encounters an event
// that invalidates the cursor. We should close the cursor and return without