diff --git a/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/IndexRecoveryIT.java b/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/IndexRecoveryIT.java index b2c02dd3cf74f..98d2235a00223 100644 --- a/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/IndexRecoveryIT.java +++ b/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/IndexRecoveryIT.java @@ -1623,7 +1623,6 @@ public void testReservesBytesDuringPeerRecoveryPhaseOne() throws Exception { ); } - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/100222") public void testWaitForClusterStateToBeAppliedOnSourceNode() throws Exception { internalCluster().startMasterOnlyNode(); final var primaryNode = internalCluster().startDataOnlyNode(); diff --git a/test/framework/src/main/java/org/elasticsearch/indices/recovery/RecoveryClusterStateDelayListeners.java b/test/framework/src/main/java/org/elasticsearch/indices/recovery/RecoveryClusterStateDelayListeners.java index c7c4d410e3ef1..192cb7d040a4b 100644 --- a/test/framework/src/main/java/org/elasticsearch/indices/recovery/RecoveryClusterStateDelayListeners.java +++ b/test/framework/src/main/java/org/elasticsearch/indices/recovery/RecoveryClusterStateDelayListeners.java @@ -74,7 +74,6 @@ public void onStartRecovery() { } public void delayUntilRecoveryStart(SubscribableListener listener) { - ESTestCase.assertFalse(startRecoveryListener.isDone()); startRecoveryListener.addListener(listener); } }