ClusterDisruptionIT.java

Author: albertzaharovits

server/src/internalClusterTest/java/org/elasticsearch/index/engine/MergeWithLowDiskSpaceIT.java

@@ -103,7 +103,7 @@ public void testShardCloseWhenDiskSpaceInsufficient() throws Exception {
             // and the merge executor says they're blocked due to insufficient disk space if (nodesStatsResponse.getNodes()
             NodesStatsResponse nodesStatsResponse = client().admin().cluster().prepareNodesStats().setThreadPool(true).get();
             if (nodesStatsResponse.getNodes()
-                .getFirst()
+                .get(0)
                 .getThreadPool()
                 .stats()
                 .stream()
@@ -131,15 +131,15 @@ public void testShardCloseWhenDiskSpaceInsufficient() throws Exception {
         assertBusy(() -> {
             expectThrows(
                 IndexNotFoundException.class,
-                () -> indicesAdmin().prepareGetIndex(TEST_REQUEST_TIMEOUT).setIndices(indexName).get()
+                () -> indicesAdmin().prepareGetIndex().setIndices(indexName).get()
             );
         });
         assertBusy(() -> {
             // merge thread pool should be done with the enqueue merge tasks
             NodesStatsResponse nodesStatsResponse = client().admin().cluster().prepareNodesStats().setThreadPool(true).get();
             assertThat(
                 nodesStatsResponse.getNodes()
-                    .getFirst()
+                    .get(0)
                     .getThreadPool()
                     .stats()
                     .stream()