summaryrefslogtreecommitdiff
path: root/src/mongo/s
diff options
context:
space:
mode:
authorKatherine Wu <katherine.wu@mongodb.com>2020-06-11 20:34:02 -0400
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2020-06-12 00:46:41 +0000
commit914d4a3ab10c0291cc1658d43534d44083cb79d9 (patch)
tree5abf685f45744757223ac9604d1b56d04ecac10a /src/mongo/s
parent351ec9947164cd78c8f003e972ba5d71f6438b53 (diff)
downloadmongo-914d4a3ab10c0291cc1658d43534d44083cb79d9.tar.gz
Revert "SERVER-46716: Add tests for let parameters for sharded update"
This reverts commit 41fd8b2a5b227dda18ab81da51e10ecafcf64a52.
Diffstat (limited to 'src/mongo/s')
-rw-r--r--src/mongo/s/commands/cluster_map_reduce_agg.cpp4
-rw-r--r--src/mongo/s/query/cluster_aggregation_planner.cpp2
2 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/s/commands/cluster_map_reduce_agg.cpp b/src/mongo/s/commands/cluster_map_reduce_agg.cpp
index 7908cdec77b..224e82dc6ca 100644
--- a/src/mongo/s/commands/cluster_map_reduce_agg.cpp
+++ b/src/mongo/s/commands/cluster_map_reduce_agg.cpp
@@ -118,9 +118,9 @@ Document serializeToCommand(BSONObj originalCmd, const MapReduce& parsedMr, Pipe
Value(Document{{"batchSize", std::numeric_limits<long long>::max()}});
translatedCmd[AggregationRequest::kAllowDiskUseName] = Value(true);
translatedCmd[AggregationRequest::kFromMongosName] = Value(true);
- translatedCmd[AggregationRequest::kRuntimeConstantsName] =
+ translatedCmd[AggregationRequest::kRuntimeConstants] =
Value(pipeline->getContext()->getRuntimeConstants().toBSON());
- translatedCmd[AggregationRequest::kIsMapReduceCommandName] = Value(true);
+ translatedCmd[AggregationRequest::kIsMapReduceCommand] = Value(true);
if (shouldBypassDocumentValidationForCommand(originalCmd)) {
translatedCmd[bypassDocumentValidationCommandOption()] = Value(true);
diff --git a/src/mongo/s/query/cluster_aggregation_planner.cpp b/src/mongo/s/query/cluster_aggregation_planner.cpp
index 5b7ea00286f..5c4716e229f 100644
--- a/src/mongo/s/query/cluster_aggregation_planner.cpp
+++ b/src/mongo/s/query/cluster_aggregation_planner.cpp
@@ -126,7 +126,7 @@ BSONObj createCommandForMergingShard(Document serializedCommand,
mergeCmd["pipeline"] = Value(pipelineForMerging->serialize());
mergeCmd[AggregationRequest::kFromMongosName] = Value(true);
- mergeCmd[AggregationRequest::kRuntimeConstantsName] =
+ mergeCmd[AggregationRequest::kRuntimeConstants] =
Value(mergeCtx->getRuntimeConstants().toBSON());
// If the user didn't specify a collation already, make sure there's a collation attached to