diff options
Diffstat (limited to 'src/mongo/s/query/cluster_aggregation_planner.cpp')
| -rw-r--r-- | src/mongo/s/query/cluster_aggregation_planner.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/s/query/cluster_aggregation_planner.cpp b/src/mongo/s/query/cluster_aggregation_planner.cpp index bf8665894b8..d3c899755cb 100644 --- a/src/mongo/s/query/cluster_aggregation_planner.cpp +++ b/src/mongo/s/query/cluster_aggregation_planner.cpp @@ -479,12 +479,12 @@ SplitPipeline splitPipeline(std::unique_ptr<Pipeline, PipelineDeleter> pipeline) } void addMergeCursorsSource(Pipeline* mergePipeline, - const LiteParsedPipeline& liteParsedPipeline, BSONObj cmdSentToShards, std::vector<OwnedRemoteCursor> ownedCursors, const std::vector<ShardId>& targetedShards, boost::optional<BSONObj> shardCursorsSortSpec, - std::shared_ptr<executor::TaskExecutor> executor) { + std::shared_ptr<executor::TaskExecutor> executor, + bool hasChangeStream) { auto* opCtx = mergePipeline->getContext()->opCtx; AsyncResultsMergerParams armParams; armParams.setSort(shardCursorsSortSpec); @@ -524,7 +524,7 @@ void addMergeCursorsSource(Pipeline* mergePipeline, auto mergeCursorsStage = DocumentSourceMergeCursors::create( std::move(executor), std::move(armParams), mergePipeline->getContext()); - if (liteParsedPipeline.hasChangeStream()) { + if (hasChangeStream) { mergePipeline->addInitialSource(DocumentSourceUpdateOnAddShard::create( mergePipeline->getContext(), Grid::get(opCtx)->getExecutorPool()->getArbitraryExecutor(), |