1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
/*
* Test that shard split generates and apply a split config.
*
* @tags: [requires_fcv_52, featureFlagShardSplit, serverless]
*/
load("jstests/libs/fail_point_util.js");
load('jstests/libs/parallel_shell_helpers.js');
load("jstests/serverless/libs/basic_serverless_test.js");
function shardSplitApplySplitConfig() {
"use strict";
jsTestLog("Checking that shard split correctly reconfig the nodes.");
// Skip db hash check because secondary is left with a different config.
TestData.skipCheckDBHashes = true;
const test =
new BasicServerlessTest({recipientTagName: "recipientNode", recipientSetName: "recipient"});
test.addRecipientNodes();
const donorPrimary = test.donor.getPrimary();
const migrationId = UUID();
const tenantIds = ["test_tenant_1", "test_tenant_2"];
jsTestLog("Asserting no state document exist before command");
assert.isnull(findMigration(donorPrimary, migrationId));
const adminDb = donorPrimary.getDB("admin");
configureFailPoint(adminDb, "skipShardSplitWaitForSplitAcceptance");
jsTestLog("Running commitShardSplit command");
assert.commandWorked(adminDb.runCommand({
commitShardSplit: 1,
migrationId,
recipientTagName: test.recipientTagName,
recipientSetName: test.recipientSetName,
tenantIds
}));
jsTestLog("Asserting state document exist after command");
assertMigrationState(donorPrimary, migrationId, "committed");
jsTestLog("Asserting a split config has been applied");
const configDoc = test.donor.getReplSetConfigFromNode();
assert(configDoc, "There must be a config document");
assert.eq(configDoc["members"].length, 3);
assert(configDoc["recipientConfig"]);
assert.eq(configDoc["recipientConfig"]["_id"], "recipient");
assert.eq(configDoc["recipientConfig"]["members"].length, 3);
jsTestLog("Running forgetShardSplit command");
assert.commandWorked(adminDb.runCommand({forgetShardSplit: 1, migrationId}));
test.stop();
}
shardSplitApplySplitConfig();
|
