diff options
| author | Allison Easton <allison.easton@mongodb.com> | 2022-02-15 11:05:11 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2022-02-15 11:47:27 +0000 |
| commit | b5d49056f67ee01108a41bf5d1b7d2532c0af500 (patch) | |
| tree | b9915fa0b5fa2f24523d24c6c4a7d080f4460c63 | |
| parent | 7ef3509ca2df4e301f19644441ce6104024512d4 (diff) | |
| download | mongo-b5d49056f67ee01108a41bf5d1b7d2532c0af500.tar.gz | |
SERVER-63608 Usage of collStats should use collection namespace not full namespace
| -rw-r--r-- | jstests/sharding/libs/defragmentation_util.js | 25 |
1 files changed, 20 insertions, 5 deletions
diff --git a/jstests/sharding/libs/defragmentation_util.js b/jstests/sharding/libs/defragmentation_util.js index 65a3e49eb18..b62276f71cd 100644 --- a/jstests/sharding/libs/defragmentation_util.js +++ b/jstests/sharding/libs/defragmentation_util.js @@ -87,8 +87,15 @@ var defragmentationUtil = (function() { const chunks = findChunksUtil.findChunksByNs(mongos.getDB('config'), ns).sort({shardKey: 1}).toArray(); const coll = mongos.getCollection(ns); - const collStats = assert.commandWorked(coll.getDB().runCommand({collStats: ns})); - const avgObjSize = collStats.avgObjSize; + const pipeline = [ + {'$collStats': {'storageStats': {}}}, + {'$project': {'shard': true, 'storageStats': {'avgObjSize': true}}} + ]; + const storageStats = coll.aggregate(pipeline).toArray(); + let avgObjSizeByShard = {}; + storageStats.forEach((storageStat) => { + avgObjSizeByShard[storageStat['shard']] = storageStat['storageStats']['avgObjSize']; + }); let checkForOversizedChunk = function( coll, chunk, shardKey, avgObjSize, oversizedChunkThreshold) { let chunkSize = @@ -110,7 +117,7 @@ var defragmentationUtil = (function() { if (chunk1Zone === chunk2Zone) { let combinedDataSize = coll.countDocuments({ shardKey: {$gte: chunk1.min[shardKey], $lt: chunk2.max[shardKey]} - }) * avgObjSize; + }) * avgObjSizeByShard[chunk1['shard']]; assert.lte( combinedDataSize, oversizedChunkThreshold, @@ -119,10 +126,18 @@ var defragmentationUtil = (function() { } } // Check for oversized chunks - checkForOversizedChunk(coll, chunk1, shardKey, avgObjSize, oversizedChunkThreshold); + checkForOversizedChunk(coll, + chunk1, + shardKey, + avgObjSizeByShard[chunk1['shard']], + oversizedChunkThreshold); } const lastChunk = chunks[chunks.length - 1]; - checkForOversizedChunk(coll, lastChunk, shardKey, avgObjSize, oversizedChunkThreshold); + checkForOversizedChunk(coll, + lastChunk, + shardKey, + avgObjSizeByShard[lastChunk['shard']], + oversizedChunkThreshold); }; let getZoneForRange = function(mongos, ns, minKey, maxKey) { |