import {ShardingTest} from "jstests/libs/shardingtest.js" ; const docs = [ {_id: 0, t: 6, m: NumberInt(0)}, {_id: 1, t: 0, m: NumberInt(0)} ]; const query = [ {$project: {a: "$t" }}, {$match: {$or: [{a: 6, m: {$ne: 1}}]}} ]; const st = new ShardingTest({shards: 2, mongos: 1}); const shardedDb = st.getDB( "test" ); assert (st.adminCommand({enablesharding: "test" , primaryShard: st.shard0.shardName})); const coll = shardedDb.coll; assert (coll.drop()); assert .commandWorked(coll.insert(docs)); assert .commandWorked(coll.createIndex({t: 1})); const resultsBeforeSharding = coll.aggregate(query).toArray() jsTestLog( 'results before sharding' ); jsTestLog(resultsBeforeSharding); // [ { "_id" : 0, "a" : 6 } ] assert (st.adminCommand({shardcollection: `test.coll`, key: {t: 1}})); // One doc on each shard assert (st.adminCommand({split: `test.coll`, middle: {t: 3}})); // shard0 has the t=0 doc, shard1 has the t=6 doc assert (st.adminCommand({moveChunk: `test.coll`, find: {t: 6}, to: st.shard1.shardName})) jsTestLog(st.getDB( "admin" ).aggregate([{$shardedDataDistribution: {}}]).toArray()) // One orphan doc exists on shard0 const resultsAfterSharding = coll.aggregate(query).toArray(); jsTestLog( 'results after sharding' ) jsTestLog(resultsAfterSharding); // [ { "_id" : 0, "a" : 6 }, { "_id" : 0, "a" : 6 } ] jsTestLog(coll.explain().aggregate(query)); // no shard filter stage assert .eq(resultsBeforeSharding, resultsAfterSharding, {resultsBeforeSharding, resultsAfterSharding}) st.stop();