spotlessApply

jimczi · Dec 11, 2023 · aea7785 · aea7785
1 parent 93063b5
commit aea7785
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 28 deletions.
diff --git a/server/src/internalClusterTest/java/org/elasticsearch/action/search/PointInTimeIT.java b/server/src/internalClusterTest/java/org/elasticsearch/action/search/PointInTimeIT.java
@@ -315,21 +315,15 @@ public void testIndexNotFound() {
             }
 
             // Allow partial search result
-            assertResponse(
-                prepareSearch().setAllowPartialSearchResults(true).setPointInTime(new PointInTimeBuilder(pit)),
-                resp -> {
-                    assertFailures(resp);
-                    assertHitCount(resp, index2);
-                }
-            );
+            assertResponse(prepareSearch().setAllowPartialSearchResults(true).setPointInTime(new PointInTimeBuilder(pit)), resp -> {
+                assertFailures(resp);
+                assertHitCount(resp, index2);
+            });
 
             // Do not allow partial search result
             expectThrows(
                 ElasticsearchException.class,
-                () -> prepareSearch()
-                    .setAllowPartialSearchResults(false)
-                    .setPointInTime(new PointInTimeBuilder(pit))
-                    .get()
+                () -> prepareSearch().setAllowPartialSearchResults(false).setPointInTime(new PointInTimeBuilder(pit)).get()
             );
         } finally {
             closePointInTime(pit);
@@ -427,14 +421,11 @@ public void testPartialResults() throws Exception {
             });
 
             internalCluster().restartNode(assignedNodeForIndex1);
-            assertResponse(
-                prepareSearch().setAllowPartialSearchResults(true).setPointInTime(new PointInTimeBuilder(pitId)),
-                resp -> {
-                    assertFailures(resp);
-                    assertThat(resp.pointInTimeId(), equalTo(pitId));
-                    assertHitCount(resp, numDocs2);
-                }
-            );
+            assertResponse(prepareSearch().setAllowPartialSearchResults(true).setPointInTime(new PointInTimeBuilder(pitId)), resp -> {
+                assertFailures(resp);
+                assertThat(resp.pointInTimeId(), equalTo(pitId));
+                assertHitCount(resp, numDocs2);
+            });
         } finally {
             closePointInTime(pitId);
         }

diff --git a/test/framework/src/main/java/org/elasticsearch/test/client/RandomizingClient.java b/test/framework/src/main/java/org/elasticsearch/test/client/RandomizingClient.java
@@ -61,8 +61,7 @@ public RandomizingClient(Client client, Random random) {
 
     @Override
     public SearchRequestBuilder prepareSearch(String... indices) {
-        SearchRequestBuilder searchRequestBuilder = new RandomizedSearchRequestBuilder(this)
-            .setIndices(indices)
+        SearchRequestBuilder searchRequestBuilder = new RandomizedSearchRequestBuilder(this).setIndices(indices)
             .setSearchType(defaultSearchType)
             .setPreference(defaultPreference)
             .setBatchedReduceSize(batchedReduceSize);

diff --git a/...ces/src/internalClusterTest/java/org/elasticsearch/index/engine/frozen/FrozenIndexIT.java b/...ces/src/internalClusterTest/java/org/elasticsearch/index/engine/frozen/FrozenIndexIT.java
@@ -232,13 +232,10 @@ public void testRetryPointInTime() throws Exception {
         ).keepAlive(TimeValue.timeValueMinutes(2));
         final String pitId = client().execute(TransportOpenPointInTimeAction.TYPE, openPointInTimeRequest).actionGet().getPointInTimeId();
         try {
-            assertNoFailuresAndResponse(
-                prepareSearch().setPointInTime(new PointInTimeBuilder(pitId)),
-                searchResponse -> {
-                    assertThat(searchResponse.pointInTimeId(), equalTo(pitId));
-                    assertHitCount(searchResponse, numDocs);
-                }
-            );
+            assertNoFailuresAndResponse(prepareSearch().setPointInTime(new PointInTimeBuilder(pitId)), searchResponse -> {
+                assertThat(searchResponse.pointInTimeId(), equalTo(pitId));
+                assertHitCount(searchResponse, numDocs);
+            });
             internalCluster().restartNode(assignedNode);
             ensureGreen(indexName);