Fixing build and addressing comment

Signed-off-by: Bharathwaj G <[email protected]>
opensearch-project · Sep 2, 2022 · 13b5f4c · 13b5f4c
1 parent 5167a2c
commit 13b5f4c
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 14 deletions.
diff --git a/client/rest-high-level/src/main/java/org/opensearch/client/RestHighLevelClient.java b/client/rest-high-level/src/main/java/org/opensearch/client/RestHighLevelClient.java
@@ -1377,11 +1377,11 @@ public final Cancellable deleteAllPitsAsync(RequestOptions options, ActionListen
      */
     public final GetAllPitNodesResponse getAllPits(RequestOptions options) throws IOException {
         return performRequestAndParseEntity(
-                new MainRequest(),
-                (request) -> RequestConverters.getAllPits(),
-                options,
-                GetAllPitNodesResponse::fromXContent,
-                emptySet()
+            new MainRequest(),
+            (request) -> RequestConverters.getAllPits(),
+            options,
+            GetAllPitNodesResponse::fromXContent,
+            emptySet()
         );
     }
 
@@ -1394,12 +1394,12 @@ public final GetAllPitNodesResponse getAllPits(RequestOptions options) throws IO
      */
     public final Cancellable getAllPitsAsync(RequestOptions options, ActionListener<GetAllPitNodesResponse> listener) {
         return performRequestAsyncAndParseEntity(
-                new MainRequest(),
-                (request) -> RequestConverters.getAllPits(),
-                options,
-                GetAllPitNodesResponse::fromXContent,
-                listener,
-                emptySet()
+            new MainRequest(),
+            (request) -> RequestConverters.getAllPits(),
+            options,
+            GetAllPitNodesResponse::fromXContent,
+            listener,
+            emptySet()
         );
     }
 

diff --git a/client/rest-high-level/src/test/java/org/opensearch/client/RestHighLevelClientTests.java b/client/rest-high-level/src/test/java/org/opensearch/client/RestHighLevelClientTests.java
@@ -135,6 +135,7 @@ public class RestHighLevelClientTests extends OpenSearchTestCase {
         "ping",
         "info",
         "delete_all_pits",
+        "get_all_pits",
         // security
         "security.get_ssl_certificates",
         "security.authenticate",

diff --git a/server/src/main/java/org/opensearch/action/search/GetAllPitNodesResponse.java b/server/src/main/java/org/opensearch/action/search/GetAllPitNodesResponse.java
@@ -45,13 +45,13 @@ public GetAllPitNodesResponse(StreamInput in) throws IOException {
 
     public GetAllPitNodesResponse(
         ClusterName clusterName,
-        List<GetAllPitNodeResponse> getAllPitNodeResponse,
+        List<GetAllPitNodeResponse> getAllPitNodeResponseList,
         List<FailedNodeException> failures
     ) {
-        super(clusterName, getAllPitNodeResponse, failures);
+        super(clusterName, getAllPitNodeResponseList, failures);
         Set<String> uniquePitIds = new HashSet<>();
         pitInfos.addAll(
-            getAllPitNodeResponse.stream()
+            getAllPitNodeResponseList.stream()
                 .flatMap(p -> p.getPitInfos().stream().filter(t -> uniquePitIds.add(t.getPitId())))
                 .collect(Collectors.toList())
         );