From f6a7a0d9a17422d8817aaf7908d8d622e1476d48 Mon Sep 17 00:00:00 2001 From: Tim Brooks Date: Fri, 13 Sep 2024 11:00:15 -0600 Subject: [PATCH] Fix --- .../org/elasticsearch/http/IncrementalBulkRestIT.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/qa/smoke-test-http/src/javaRestTest/java/org/elasticsearch/http/IncrementalBulkRestIT.java b/qa/smoke-test-http/src/javaRestTest/java/org/elasticsearch/http/IncrementalBulkRestIT.java index 4b3b6fbb2a719..8b501c1152d47 100644 --- a/qa/smoke-test-http/src/javaRestTest/java/org/elasticsearch/http/IncrementalBulkRestIT.java +++ b/qa/smoke-test-http/src/javaRestTest/java/org/elasticsearch/http/IncrementalBulkRestIT.java @@ -88,9 +88,7 @@ public void testBulkWithIncrementalDisabled() throws IOException { final Response indexSuccessFul = getRestClient().performRequest(firstBulkRequest); assertThat(indexSuccessFul.getStatusLine().getStatusCode(), equalTo(OK.getStatus())); - clusterAdmin().prepareUpdateSettings() - .setPersistentSettings(Settings.builder().put(IncrementalBulkService.INCREMENTAL_BULK.getKey(), false).build()) - .get(); + updateClusterSettings(Settings.builder().put(IncrementalBulkService.INCREMENTAL_BULK.getKey(), false)); internalCluster().getInstances(IncrementalBulkService.class).forEach(i -> i.setForTests(false)); @@ -98,9 +96,7 @@ public void testBulkWithIncrementalDisabled() throws IOException { sendLargeBulk(); } finally { internalCluster().getInstances(IncrementalBulkService.class).forEach(i -> i.setForTests(true)); - clusterAdmin().prepareUpdateSettings() - .setPersistentSettings(Settings.builder().put(IncrementalBulkService.INCREMENTAL_BULK.getKey(), (String) null).build()) - .get(); + updateClusterSettings(Settings.builder().put(IncrementalBulkService.INCREMENTAL_BULK.getKey(), (String) null)); } }