diff --git a/x-pack/qa/full-cluster-restart/src/test/java/org/elasticsearch/xpack/restart/FullClusterRestartIT.java b/x-pack/qa/full-cluster-restart/src/test/java/org/elasticsearch/xpack/restart/FullClusterRestartIT.java index 27b717323fe25..28e3340ee7bc9 100644 --- a/x-pack/qa/full-cluster-restart/src/test/java/org/elasticsearch/xpack/restart/FullClusterRestartIT.java +++ b/x-pack/qa/full-cluster-restart/src/test/java/org/elasticsearch/xpack/restart/FullClusterRestartIT.java @@ -146,7 +146,6 @@ public void testSecurityNativeRealm() throws Exception { } @SuppressWarnings("unchecked") - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/48381") public void testWatcher() throws Exception { if (isRunningAgainstOldCluster()) { logger.info("Adding a watch on old cluster {}", getOldClusterVersion()); @@ -169,13 +168,25 @@ public void testWatcher() throws Exception { client().performRequest(createFunnyTimeout); logger.info("Waiting for watch results index to fill up..."); - waitForYellow(".watches,bwc_watch_index,.watcher-history*"); + try { + waitForYellow(".watches,bwc_watch_index,.watcher-history*"); + } catch (ResponseException e) { + String rsp = toStr(client().performRequest(new Request("GET", "/_cluster/state"))); + logger.info("cluster_state_response=\n{}", rsp); + throw e; + } waitForHits("bwc_watch_index", 2); waitForHits(".watcher-history*", 2); logger.info("Done creating watcher-related indices"); } else { logger.info("testing against {}", getOldClusterVersion()); - waitForYellow(".watches,bwc_watch_index,.watcher-history*"); + try { + waitForYellow(".watches,bwc_watch_index,.watcher-history*"); + } catch (ResponseException e) { + String rsp = toStr(client().performRequest(new Request("GET", "/_cluster/state"))); + logger.info("cluster_state_response=\n{}", rsp); + throw e; + } logger.info("checking that the Watches index is the correct version");