summaryrefslogtreecommitdiff
path: root/jstests/sharding/agg_merge_hashed.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/agg_merge_hashed.js')
-rw-r--r--jstests/sharding/agg_merge_hashed.js3
1 files changed, 2 insertions, 1 deletions
diff --git a/jstests/sharding/agg_merge_hashed.js b/jstests/sharding/agg_merge_hashed.js
index 586dd65c9c8..9b8772c7b23 100644
--- a/jstests/sharding/agg_merge_hashed.js
+++ b/jstests/sharding/agg_merge_hashed.js
@@ -6,6 +6,7 @@
load("jstests/aggregation/extras/merge_helpers.js");
load("jstests/sharding/libs/chunk_bounds_util.js");
+load("jstests/sharding/libs/find_chunks_util.js");
let st = new ShardingTest({shards: 3});
let dbName = "test";
@@ -19,7 +20,7 @@ let targetNs = targetColl.getFullName();
assert.commandWorked(st.s.adminCommand({enableSharding: dbName}));
assert.commandWorked(st.s.adminCommand({shardCollection: targetNs, key: {x: 'hashed'}}));
-let chunkDocsForTargetColl = configDB.chunks.find({ns: targetNs}).toArray();
+let chunkDocsForTargetColl = findChunksUtil.findChunksByNs(configDB, targetNs).toArray();
let shardChunkBoundsForTargetColl = chunkBoundsUtil.findShardChunkBounds(chunkDocsForTargetColl);
// Use docs that are expected to go to three different shards.