diff options
| author | Charlie Swanson <charlie.swanson@mongodb.com> | 2018-11-29 17:39:33 -0500 |
|---|---|---|
| committer | Charlie Swanson <charlie.swanson@mongodb.com> | 2019-01-16 10:09:59 -0500 |
| commit | 0cb2195939494660334db8e9d0a52509caeb621c (patch) | |
| tree | 2d71e10270020f2e7ea8bf3bfb812b13f83abbca /src/mongo/db/pipeline/pipeline.cpp | |
| parent | d29f140ae0e69057d8b1801f4d2a993612fa5bcb (diff) | |
| download | mongo-0cb2195939494660334db8e9d0a52509caeb621c.tar.gz | |
SERVER-38311 Adjust $out merging strategy
Diffstat (limited to 'src/mongo/db/pipeline/pipeline.cpp')
| -rw-r--r-- | src/mongo/db/pipeline/pipeline.cpp | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/mongo/db/pipeline/pipeline.cpp b/src/mongo/db/pipeline/pipeline.cpp index 725c655be44..1fddc890a17 100644 --- a/src/mongo/db/pipeline/pipeline.cpp +++ b/src/mongo/db/pipeline/pipeline.cpp @@ -390,8 +390,7 @@ bool Pipeline::requiredToRunOnMongos() const { for (auto&& stage : _sources) { // If this pipeline is capable of splitting before the mongoS-only stage, then the pipeline // as a whole is not required to run on mongoS. - if (_splitState == SplitState::kUnsplit && - dynamic_cast<NeedsMergerDocumentSource*>(stage.get())) { + if (_splitState == SplitState::kUnsplit && stage->mergingLogic()) { return false; } |