diff options
Diffstat (limited to 'jstests/sharding')
| -rw-r--r-- | jstests/sharding/resharding_coordinator_recovers_abort_decision.js | 6 |
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(); }, |