summaryrefslogtreecommitdiff
path: root/jstests/multiVersion
diff options
context:
space:
mode:
authorSuganthi Mani <suganthi.mani@mongodb.com>2021-11-02 20:07:09 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-11-02 20:53:19 +0000
commitbbc96fbba2deaac539165bcd86bbdaf6037f41dd (patch)
treed45d57646ae12e4d347fc25b00e72c7b54eb7c71 /jstests/multiVersion
parentd47a25210252140172b9f8aa99f78662d7c1fcaf (diff)
downloadmongo-bbc96fbba2deaac539165bcd86bbdaf6037f41dd.tar.gz
SERVER-59495 Donor and recipient tenant migration state machines will persist the migration protocol info and tenantId info will be an empty string for 'Merge' protocol.
Diffstat (limited to 'jstests/multiVersion')
-rw-r--r--jstests/multiVersion/genericSetFCVUsage/tenant_migration_save_fcv.js10
1 files changed, 9 insertions, 1 deletions
diff --git a/jstests/multiVersion/genericSetFCVUsage/tenant_migration_save_fcv.js b/jstests/multiVersion/genericSetFCVUsage/tenant_migration_save_fcv.js
index a7881fef8aa..19a5e7eae83 100644
--- a/jstests/multiVersion/genericSetFCVUsage/tenant_migration_save_fcv.js
+++ b/jstests/multiVersion/genericSetFCVUsage/tenant_migration_save_fcv.js
@@ -52,6 +52,9 @@ function runTest(downgradeFCV) {
migrationThread.start();
hangAfterSavingFCV.wait();
+ const isRunningMergeProtocol =
+ (TenantMigrationUtil.isShardMergeEnabled(recipientDb)) ? true : false;
+
// Downgrade the FCV for the recipient set.
assert.commandWorked(
recipientPrimary.adminCommand({setFeatureCompatibilityVersion: downgradeFCV}));
@@ -66,7 +69,12 @@ function runTest(downgradeFCV) {
// The migration will not be able to continue in the downgraded version.
TenantMigrationTest.assertAborted(migrationThread.returnData());
- checkLog.containsJson(newRecipientPrimary, 5356200); // Change-of-FCV detection message.
+ // Change-of-FCV detection message.
+ if (isRunningMergeProtocol) {
+ checkLog.containsJson(newRecipientPrimary, 5949504);
+ } else {
+ checkLog.containsJson(newRecipientPrimary, 5356200);
+ }
tenantMigrationTest.stop();
recipientRst.stopSet();