diff options
Diffstat (limited to 'src/mongo/s/commands/cluster_map_reduce_agg.cpp')
| -rw-r--r-- | src/mongo/s/commands/cluster_map_reduce_agg.cpp | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/src/mongo/s/commands/cluster_map_reduce_agg.cpp b/src/mongo/s/commands/cluster_map_reduce_agg.cpp index 66755ea7d16..38caba355de 100644 --- a/src/mongo/s/commands/cluster_map_reduce_agg.cpp +++ b/src/mongo/s/commands/cluster_map_reduce_agg.cpp @@ -34,6 +34,7 @@ #include "mongo/bson/util/bson_extract.h" #include "mongo/client/connpool.h" #include "mongo/db/auth/authorization_session.h" +#include "mongo/db/catalog/document_validation.h" #include "mongo/db/client.h" #include "mongo/db/commands.h" #include "mongo/db/commands/map_reduce_agg.h" @@ -113,6 +114,15 @@ Document serializeToCommand(BSONObj originalCmd, const MapReduce& parsedMr, Pipe translatedCmd[AggregationRequest::kRuntimeConstants] = Value(pipeline->getContext()->getRuntimeConstants().toBSON()); + if (shouldBypassDocumentValidationForCommand(originalCmd)) { + translatedCmd[bypassDocumentValidationCommandOption()] = Value(true); + } + + if (originalCmd[AggregationRequest::kCollationName]) { + translatedCmd[AggregationRequest::kCollationName] = + Value(originalCmd[AggregationRequest::kCollationName]); + } + // TODO SERVER-44884: We set this flag to indicate that the shards should always use the new // upsert mechanism when executing relevant $merge modes. After branching for 4.5, supported // upgrade versions will all use the new mechanism, and we can remove this flag. @@ -224,7 +234,6 @@ bool runAggregationMapReduce(OperationContext* opCtx, if (verbosity) { map_reduce_output_format::appendExplainResponse(result, aggResults); } else if (parsedMr.getOutOptions().getOutputType() == OutputType::InMemory) { - // TODO SERVER-43290: Add support for cluster MapReduce statistics. // If the inline results could not fit into a single batch, then kill the remote // operation(s) and return an error since mapReduce does not support a cursor-style // response. |