diff --git a/server/src/main/java/org/elasticsearch/rest/action/search/HttpChannelTaskHandler.java b/server/src/main/java/org/elasticsearch/rest/action/search/HttpChannelTaskHandler.java index 5864551854f..efda0c55f28 100644 --- a/server/src/main/java/org/elasticsearch/rest/action/search/HttpChannelTaskHandler.java +++ b/server/src/main/java/org/elasticsearch/rest/action/search/HttpChannelTaskHandler.java @@ -58,7 +58,7 @@ public final class HttpChannelTaskHandler { CloseListener closeListener = httpChannels.computeIfAbsent(httpChannel, channel -> new CloseListener(client)); TaskHolder taskHolder = new TaskHolder(); Task task = client.executeLocally(actionType, request, - new ActionListener<>() { + new ActionListener() { @Override public void onResponse(Response searchResponse) { try {