summaryrefslogtreecommitdiff
path: root/src/mongo/s/query/cluster_aggregation_planner.cpp
diff options
context:
space:
mode:
authorRishab Joshi <rishab.joshi@mongodb.com>2021-05-11 14:12:34 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-05-20 00:55:21 +0000
commite53e42046e8e25f4cf9b6ffa68c71c2add8ae793 (patch)
tree14ed8d4743ef7146ee6da8f255f6fd3b1657a720 /src/mongo/s/query/cluster_aggregation_planner.cpp
parent189c806cc7ec182173ed82c85503f30472a25b5b (diff)
downloadmongo-e53e42046e8e25f4cf9b6ffa68c71c2add8ae793.tar.gz
SERVER-56696: Introduce a new change stream stage to handle the topology
change event.
Diffstat (limited to 'src/mongo/s/query/cluster_aggregation_planner.cpp')
-rw-r--r--src/mongo/s/query/cluster_aggregation_planner.cpp3
1 files changed, 1 insertions, 2 deletions
diff --git a/src/mongo/s/query/cluster_aggregation_planner.cpp b/src/mongo/s/query/cluster_aggregation_planner.cpp
index 8714c6b1aad..a9686f15920 100644
--- a/src/mongo/s/query/cluster_aggregation_planner.cpp
+++ b/src/mongo/s/query/cluster_aggregation_planner.cpp
@@ -296,8 +296,7 @@ BSONObj establishMergingMongosCursor(OperationContext* opCtx,
// to the resume token of the invalidating event, and mark the cursor response as
// invalidated. We always expect to have ExtraInfo for this error code.
const auto extraInfo = ex.extraInfo<ChangeStreamInvalidationInfo>();
- tassert(
- 5493706, "Missing ChangeStreamInvalidationInfo on exception", extraInfo != nullptr);
+ tassert(5493706, "Missing ChangeStreamInvalidationInfo on exception", extraInfo);
responseBuilder.setPostBatchResumeToken(extraInfo->getInvalidateResumeToken());
responseBuilder.setInvalidated();