diff options
author | mathisbessamdb <mathis.bessa@mongodb.com> | 2022-05-10 22:59:14 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-05-10 23:26:48 +0000 |
commit | e22aedb467254e680b705f04642e8770264af42d (patch) | |
tree | 52f43addd3c8c36d0e386b5c6de79e0bda39ad95 /jstests/serverless/shard_split_wait_for_block_timestamp.js | |
parent | 6a16461988b990f6ea2ebe4e129bad1addada035 (diff) | |
download | mongo-e22aedb467254e680b705f04642e8770264af42d.tar.gz |
SERVER-64906 Copy applicable Tenant Migration jstests to shard split
Diffstat (limited to 'jstests/serverless/shard_split_wait_for_block_timestamp.js')
-rw-r--r-- | jstests/serverless/shard_split_wait_for_block_timestamp.js | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/jstests/serverless/shard_split_wait_for_block_timestamp.js b/jstests/serverless/shard_split_wait_for_block_timestamp.js index 9399b46f909..1797a8f2f95 100644 --- a/jstests/serverless/shard_split_wait_for_block_timestamp.js +++ b/jstests/serverless/shard_split_wait_for_block_timestamp.js @@ -42,26 +42,26 @@ assert.commandWorked(bulk.execute()); jsTestLog("Running commitShardSplit command"); const firstOperation = test.createSplitOperation(tenantIds); -assert.isnull(findMigration(donorPrimary, firstOperation.migrationId)); +assert.isnull(findSplitOperation(donorPrimary, firstOperation.migrationId)); const res = firstOperation.commit({retryOnRetryableErrors: false}); assert.commandFailed(res); assert.eq(res.code, ErrorCodes.TenantMigrationAborted); firstOperation.forget(); -test.waitForGarbageCollection(firstOperation.migrationId, tenantIds); +test.cleanupSuccesfulAbortedOrCommitted(firstOperation.migrationId, tenantIds); jsTestLog("Restarting replication on recipient nodes, and running new split operation"); +test.addRecipientNodes(); test.recipientNodes.forEach(node => restartServerReplication(node)); test.donor.awaitReplication(); test.donor.nodes.forEach( node => assert.commandWorked(setParameter(node, "shardSplitTimeoutMS", 60 * 1000))); const secondOperation = test.createSplitOperation(tenantIds); -assert.isnull(findMigration(donorPrimary, secondOperation.migrationId)); +assert.isnull(findSplitOperation(donorPrimary, secondOperation.migrationId)); assert.commandWorked(secondOperation.commit()); assertMigrationState(donorPrimary, secondOperation.migrationId, "committed"); -test.removeRecipientNodesFromDonor(); secondOperation.forget(); test.waitForGarbageCollection(secondOperation.migrationId, tenantIds); |