diff --git a/server/src/main/java/org/opensearch/grpc/services/nodesInfo/NodesInfoServiceImpl.java b/server/src/main/java/org/opensearch/grpc/services/nodesInfo/NodesInfoServiceImpl.java index 4db1264e8b5c9..fb037aff74cae 100644 --- a/server/src/main/java/org/opensearch/grpc/services/nodesInfo/NodesInfoServiceImpl.java +++ b/server/src/main/java/org/opensearch/grpc/services/nodesInfo/NodesInfoServiceImpl.java @@ -57,14 +57,7 @@ public void getNodesInfo(NodesInfoProtoService.NodesInfoRequestProto request, St responseObserver.onNext(respToProto(response)); responseObserver.onCompleted(); } - - @Override - public void streamNodesInfo(NodesInfoProtoService.NodesInfoRequestProto request, StreamObserver responseObserver) { - responseObserver.onError( - Status.UNIMPLEMENTED.withDescription("Method StreamNodesInfo is not implemented").asRuntimeException() - ); - } - + private static NodesInfoRequest reqFromProto(NodesInfoProtoService.NodesInfoRequestProto request) { String[] nodeIds = request.getNodeIdsList().toArray(new String[0]); NodesInfoRequest nodesInfoRequest = new NodesInfoRequest(nodeIds); diff --git a/server/src/main/proto/org/opensearch/action/admin/cluster/node/info/NodesInfoService.proto b/server/src/main/proto/org/opensearch/action/admin/cluster/node/info/NodesInfoService.proto index 69cd2b65a909d..3ff076f33d6e4 100644 --- a/server/src/main/proto/org/opensearch/action/admin/cluster/node/info/NodesInfoService.proto +++ b/server/src/main/proto/org/opensearch/action/admin/cluster/node/info/NodesInfoService.proto @@ -38,5 +38,4 @@ message NodesInfoResponseProto { service NodesInfoService { rpc GetNodesInfo(NodesInfoRequestProto) returns (NodesInfoResponseProto) {} - rpc StreamNodesInfo(NodesInfoRequestProto) returns (stream NodesInfoResponseProto) {} }