diff options
| author | samantharitter <samantha.ritter@10gen.com> | 2017-10-10 16:42:43 -0400 |
|---|---|---|
| committer | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2017-10-10 17:58:36 -0400 |
| commit | 953df5a1f04dafa56d1c1fb37f66438ba0698d4e (patch) | |
| tree | 44132a40a0f145878cc0c47e2e6443952b2df3e2 /jstests/sharding/auto_rebalance_parallel_replica_sets.js | |
| parent | 9094279371cc1573fed720541555d9ae05a36eb4 (diff) | |
| download | mongo-953df5a1f04dafa56d1c1fb37f66438ba0698d4e.tar.gz | |
SERVER-31184 Make sharding tests only consider chunks for collections they actually use
Diffstat (limited to 'jstests/sharding/auto_rebalance_parallel_replica_sets.js')
| -rw-r--r-- | jstests/sharding/auto_rebalance_parallel_replica_sets.js | 30 |
1 files changed, 24 insertions, 6 deletions
diff --git a/jstests/sharding/auto_rebalance_parallel_replica_sets.js b/jstests/sharding/auto_rebalance_parallel_replica_sets.js index ddc533b843b..a5a6d1bde09 100644 --- a/jstests/sharding/auto_rebalance_parallel_replica_sets.js +++ b/jstests/sharding/auto_rebalance_parallel_replica_sets.js @@ -26,18 +26,36 @@ assert.commandWorked(st.moveChunk('TestDB.TestColl', {Key: 20}, st.shard1.shardName)); assert.commandWorked(st.moveChunk('TestDB.TestColl', {Key: 30}, st.shard1.shardName)); - assert.eq(2, st.s0.getDB('config').chunks.find({shard: st.shard0.shardName}).itcount()); - assert.eq(2, st.s0.getDB('config').chunks.find({shard: st.shard1.shardName}).itcount()); + assert.eq(2, + st.s0.getDB('config') + .chunks.find({ns: 'TestDB.TestColl', shard: st.shard0.shardName}) + .itcount()); + assert.eq(2, + st.s0.getDB('config') + .chunks.find({ns: 'TestDB.TestColl', shard: st.shard1.shardName}) + .itcount()); // Do enable the balancer and wait for a single balancer round st.startBalancer(); st.awaitBalancerRound(); st.stopBalancer(); - assert.eq(1, st.s0.getDB('config').chunks.find({shard: st.shard0.shardName}).itcount()); - assert.eq(1, st.s0.getDB('config').chunks.find({shard: st.shard1.shardName}).itcount()); - assert.eq(1, st.s0.getDB('config').chunks.find({shard: st.shard2.shardName}).itcount()); - assert.eq(1, st.s0.getDB('config').chunks.find({shard: st.shard3.shardName}).itcount()); + assert.eq(1, + st.s0.getDB('config') + .chunks.find({ns: 'TestDB.TestColl', shard: st.shard0.shardName}) + .itcount()); + assert.eq(1, + st.s0.getDB('config') + .chunks.find({ns: 'TestDB.TestColl', shard: st.shard1.shardName}) + .itcount()); + assert.eq(1, + st.s0.getDB('config') + .chunks.find({ns: 'TestDB.TestColl', shard: st.shard2.shardName}) + .itcount()); + assert.eq(1, + st.s0.getDB('config') + .chunks.find({ns: 'TestDB.TestColl', shard: st.shard3.shardName}) + .itcount()); // Ensure the range deleter quiesces st.rs0.awaitReplication(); |