mongodb/mongo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SERVER-117481 Add change stream placement notifications for timeseries upgrade/downgrade coordinator (#52427)

Browse Source 
GitOrigin-RevId: 2237c11f0d1cd24465f1f3033d13a3cb0db44cce
This commit is contained in:
Denis Grebennicov 2026-05-04 18:58:37 +02:00 committed by MongoDB Bot
parent f7dc506b2e
commit e1d021b91e
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
jstests/multiVersion/genericChangeStreams/change_streams_timeseries_fcv_upgrade_downgrade.js
View File

@ -914,6 +914,7 @@ for (const [downgradeFCV, testHelper] of crossProduct(
const cursor = openChangeStreamCursor(cst, 1, {
showSystemEvents: false,
watchMode: ChangeStreamWatchMode.kDb,
version: "v1", // Matches mongos's own selection at downgraded FCV.
});
insertData("preUpgrade");
@ -993,6 +994,7 @@ for (const [downgradeFCV, testHelper] of crossProduct(
showSystemEvents: true,
watchMode,
comment,
version: "v1", // Matches mongos's own selection at downgraded FCV.
});
{

5
src/mongo/db/global_catalog/ddl/timeseries_upgrade_downgrade_coordinator.cpp
View File

@ -482,11 +482,6 @@ ExecutorFuture<void> TimeseriesUpgradeDowngradeCoordinator::_runImpl(
defaultMajorityWriteConcern(),
osi,
**executor);
// TODO SERVER-117481: Generate placement change notifications for change streams.
// Similar to rename coordinator (kSetupChangeStreamsPreconditions phase), we need
// to notify change stream readers about the namespace change from oldTrackedNss
// to newTrackedNss using generatePlacementChangeNotificationOnShard().
}))
.then(_buildPhaseHandler(
Phase::kReleaseCriticalSection,