Wait for the store to be closed, don't assume it happens immediately. Closes #135443
@@ -353,7 +353,7 @@ public class MergeWithFailureIT extends ESIntegTestCase {
ensureRed(indexName);
// verify that the shard store is effectively closed
- assertTrue(plugin.shardStoreClosedListener.isDone());
+ safeGet(plugin.shardStoreClosedListener);
if (closingThread != null) {
closingThread.join();