diff --git a/server/src/test/java/org/elasticsearch/cluster/coordination/CoordinatorTests.java b/server/src/test/java/org/elasticsearch/cluster/coordination/CoordinatorTests.java index 9bb4e808d8b79..623d3fdc34bda 100644 --- a/server/src/test/java/org/elasticsearch/cluster/coordination/CoordinatorTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/coordination/CoordinatorTests.java @@ -872,7 +872,6 @@ public void testJoiningNodeReceivesFullState() { assertEquals(0L, newNodePublishStats.getIncompatibleClusterStateDiffReceivedCount()); } - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/38867") public void testIncompatibleDiffResendsFullState() { final Cluster cluster = new Cluster(randomIntBetween(3, 5)); cluster.runRandomly(); @@ -885,12 +884,12 @@ public void testIncompatibleDiffResendsFullState() { final PublishClusterStateStats prePublishStats = follower.coordinator.stats().getPublishStats(); logger.info("--> submitting first value to {}", leader); leader.submitValue(randomLong()); - cluster.runFor(DEFAULT_CLUSTER_STATE_UPDATE_DELAY + defaultMillis(PUBLISH_TIMEOUT_SETTING), "publish first state"); + cluster.runFor(DEFAULT_CLUSTER_STATE_UPDATE_DELAY, "publish first state"); logger.info("--> healing {}", follower); follower.heal(); logger.info("--> submitting second value to {}", leader); leader.submitValue(randomLong()); - cluster.stabilise(DEFAULT_CLUSTER_STATE_UPDATE_DELAY); + cluster.stabilise(); final PublishClusterStateStats postPublishStats = follower.coordinator.stats().getPublishStats(); assertEquals(prePublishStats.getFullClusterStateReceivedCount() + 1, postPublishStats.getFullClusterStateReceivedCount());