diff options
| author | Lucas de Castro Borges <lucas@gnuabordo.com.br> | 2025-02-11 15:07:35 -0300 |
|---|---|---|
| committer | Lucas de Castro Borges <lucas@gnuabordo.com.br> | 2025-02-11 15:07:35 -0300 |
| commit | 4cb8841196d0625dfa3825aa326f071cd27c7b8b (patch) | |
| tree | 1682a647d4463397c119183369ae6f750d5fdcff /jstests/sharding/balancer_window.js | |
| parent | aa03c6362cbaa767638e6eed9b031d86dd2643d1 (diff) | |
| parent | 8f0827553e09872941945a093b647a4211a9db7f (diff) | |
Update upstream source from tag 'upstream/6.0.0'master
Update to upstream version '6.0.0'
with Debian dir 5604a80ec1c96ca76f25f40d78e6ef855abec322
Diffstat (limited to 'jstests/sharding/balancer_window.js')
| -rw-r--r-- | jstests/sharding/balancer_window.js | 26 |
1 files changed, 10 insertions, 16 deletions
diff --git a/jstests/sharding/balancer_window.js b/jstests/sharding/balancer_window.js index 0e93d967363..ee48db64844 100644 --- a/jstests/sharding/balancer_window.js +++ b/jstests/sharding/balancer_window.js @@ -45,23 +45,17 @@ var HourAndMinute = function(hour, minutes) { }; }; -const st = new ShardingTest({shards: 2, other: {chunkSize: 1, enableAutoSplit: false}}); -const dbName = 'test'; -const collName = 'user'; -const ns = dbName + '.' + collName; -const configDB = st.s.getDB('config'); -assert.commandWorked(configDB.adminCommand({enableSharding: dbName})); -assert.commandWorked(configDB.adminCommand({shardCollection: ns, key: {_id: 1}})); +var st = new ShardingTest({shards: 2}); +var configDB = st.s.getDB('config'); +assert.commandWorked(configDB.adminCommand({enableSharding: 'test'})); +assert.commandWorked(configDB.adminCommand({shardCollection: 'test.user', key: {_id: 1}})); -const bigString = 'X'.repeat(1024 * 1024); // 1MB -const coll = st.s.getDB(dbName).getCollection(collName); for (var x = 0; x < 150; x += 10) { - coll.insert({_id: x, s: bigString}); - configDB.adminCommand({split: ns, middle: {_id: x}}); + configDB.adminCommand({split: 'test.user', middle: {_id: x}}); } var shard0Chunks = - findChunksUtil.findChunksByNs(configDB, ns, {shard: st.shard0.shardName}).count(); + findChunksUtil.findChunksByNs(configDB, 'test.user', {shard: st.shard0.shardName}).count(); var startDate = new Date(); var hourMinStart = new HourAndMinute(startDate.getHours(), startDate.getMinutes()); @@ -78,10 +72,10 @@ assert.commandWorked( true)); st.startBalancer(); -st.awaitBalancerRound(); +st.waitForBalancer(true, 60000); var shard0ChunksAfter = - findChunksUtil.findChunksByNs(configDB, ns, {shard: st.shard0.shardName}).count(); + findChunksUtil.findChunksByNs(configDB, 'test.user', {shard: st.shard0.shardName}).count(); assert.eq(shard0Chunks, shard0ChunksAfter); assert.commandWorked(configDB.settings.update( @@ -93,10 +87,10 @@ assert.commandWorked(configDB.settings.update( }, true)); -st.awaitBalancerRound(); +st.waitForBalancer(true, 60000); shard0ChunksAfter = - findChunksUtil.findChunksByNs(configDB, ns, {shard: st.shard0.shardName}).count(); + findChunksUtil.findChunksByNs(configDB, 'test.user', {shard: st.shard0.shardName}).count(); assert.neq(shard0Chunks, shard0ChunksAfter); st.stop(); |
