Use a cluster client after a cluster restart

After a cluster restart an old client could be using a node that's restarting still (throwing `NodeClosedException`).
andreidan · Feb 2, 2024 · 529b124 · 529b124
1 parent e87f58d
commit 529b124
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...st/java/org/elasticsearch/xpack/downsample/DataStreamLifecycleDownsampleDisruptionIT.java b/...st/java/org/elasticsearch/xpack/downsample/DataStreamLifecycleDownsampleDisruptionIT.java
@@ -56,7 +56,6 @@ protected Settings nodeSettings(int nodeOrdinal, Settings otherSettings) {
         return settings.build();
     }
 
-    @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/99520")
     @TestLogging(value = "org.elasticsearch.datastreams.lifecycle:TRACE", reason = "debugging")
     public void testDataStreamLifecycleDownsampleRollingRestart() throws Exception {
         final InternalTestCluster cluster = internalCluster();
@@ -132,7 +131,8 @@ public boolean validateClusterForming() {
         final String targetIndex = "downsample-5m-" + sourceIndex;
         assertBusy(() -> {
             try {
-                GetSettingsResponse getSettingsResponse = client().admin()
+                GetSettingsResponse getSettingsResponse = cluster.client()
+                    .admin()
                     .indices()
                     .getSettings(new GetSettingsRequest().indices(targetIndex))
                     .actionGet();