1 files changed, 62 insertions, 0 deletions
diff --git a/jstests/sharding/change_stream_no_drop.js b/jstests/sharding/change_stream_no_drop.js
new file mode 100644
index 00000000000..d378421cd18
--- /dev/null
+++ b/jstests/sharding/change_stream_no_drop.js
@@ -0,0 +1,62 @@
+/**
+ * DDL coordinator are responsible for dropping temporary collections, especially after failures.
+ * However, the change stream should not be aware of those events.
+ * @tags: [
+ *  # Requires all nodes to be running the latest binary.
+ *  multiversion_incompatible,
+ * ]
+ */
+function assertNoDrop(changeStream) {
+    while (changeStream.hasNext()) {
+        assert.neq(changeStream.next().operationType, 'drop');
+    }
+}
+
+function emptyChangeStream(changeStream) {
+    while (changeStream.hasNext()) {
+        changeStream.next();
+    }
+}
+
+(function() {
+
+const dbName = 'db';
+
+load('jstests/libs/fail_point_util.js');  // For configureFailPoint
+
+// Enable explicitly the periodic no-op writer to allow the router to process change stream events
+// coming from all shards. This is enabled for production clusters by default.
+const st = new ShardingTest({
+    mongos: 1,
+    config: 1,
+    shards: 2,
+    rs: {nodes: 1, setParameter: {writePeriodicNoops: true, periodicNoopIntervalSecs: 1}},
+    other: {enableBalancer: true}
+});
+
+// create a database and a change stream on it
+jsTest.log('Creating a change stream on ' + dbName);
+assert.commandWorked(
+    st.s.adminCommand({enableSharding: dbName, primaryShard: st.shard0.shardName}));
+let changeStream = st.s.getDB('db').watch();
+
+// setFeatureCompatibilityVersion might cause dropping of deprecated collections
+emptyChangeStream(changeStream);
+
+jsTest.log(
+    'The shard_collection_coordinator at second attempt (after failure) should not report drop events for orphaned');
+{
+    configureFailPoint(st.shard0,
+                       'failAtCommitCreateCollectionCoordinator',
+                       data = {},
+                       failPointMode = {times: 1});
+
+    collectionName = dbName + '.coll';
+    assert.commandWorked(st.s.adminCommand(
+        {shardCollection: collectionName, key: {_id: "hashed"}, numInitialChunks: 10}));
+
+    assertNoDrop(changeStream);
+}
+
+st.stop();
+}());