summaryrefslogtreecommitdiff
path: root/jstests/sharding/resharding_coordinator_recovers_abort_decision.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/resharding_coordinator_recovers_abort_decision.js')
-rw-r--r--jstests/sharding/resharding_coordinator_recovers_abort_decision.js6
1 files changed, 6 insertions, 0 deletions
diff --git a/jstests/sharding/resharding_coordinator_recovers_abort_decision.js b/jstests/sharding/resharding_coordinator_recovers_abort_decision.js
index 40ed950b40c..357b155512c 100644
--- a/jstests/sharding/resharding_coordinator_recovers_abort_decision.js
+++ b/jstests/sharding/resharding_coordinator_recovers_abort_decision.js
@@ -109,6 +109,12 @@ reshardingTest.withReshardingInBackground(
const idx = reshardCollectionJoinedFailPointsList.findIndex(fp => fp.conn.host ===
configsvrPrimary.host);
reshardCollectionJoinedFailPointsList[idx].wait();
+
+ // Wait for secondaries to recover and catchup with primary before turning off the
+ // failpoints as a replication roll back can disconnect the test client.
+ const configRS = reshardingTest.getReplSetForShard(reshardingTest.configShardName);
+ configRS.awaitSecondaryNodes();
+ configRS.awaitReplication();
reshardCollectionJoinedFailPointsList.forEach(fp => fp.off());
shardsvrAbortReshardCollectionFailpoint.off();
},