diff --git a/qa/sql/src/main/java/org/elasticsearch/xpack/qa/sql/embed/ProtoHandler.java b/qa/sql/src/main/java/org/elasticsearch/xpack/qa/sql/embed/ProtoHandler.java index 05ab4b23068..d1076aa4e73 100644 --- a/qa/sql/src/main/java/org/elasticsearch/xpack/qa/sql/embed/ProtoHandler.java +++ b/qa/sql/src/main/java/org/elasticsearch/xpack/qa/sql/embed/ProtoHandler.java @@ -29,8 +29,7 @@ import static org.elasticsearch.common.unit.TimeValue.timeValueMinutes; public abstract class ProtoHandler implements HttpHandler, AutoCloseable { private static PlanExecutor planExecutor(EmbeddedModeFilterClient client) { - Supplier clusterStateSupplier = - () -> client.admin().cluster().prepareState().get(timeValueMinutes(1)).getState(); + Supplier clusterStateSupplier = () -> client.admin().cluster().prepareState().get(timeValueMinutes(1)).getState(); return new PlanExecutor(client, clusterStateSupplier, EsCatalog::new); } @@ -43,7 +42,8 @@ public abstract class ProtoHandler implements HttpHandler, AutoCloseable { protected ProtoHandler(Client client) { NodesInfoResponse niResponse = client.admin().cluster().prepareNodesInfo("_local").clear().get(TV); - this.client = !(client instanceof EmbeddedModeFilterClient) ? new EmbeddedModeFilterClient(client) : (EmbeddedModeFilterClient) client; + this.client = !(client instanceof EmbeddedModeFilterClient) ? new EmbeddedModeFilterClient( + client) : (EmbeddedModeFilterClient) client; this.client.setPlanExecutor(planExecutor(this.client)); info = niResponse.getNodes().get(0); clusterName = niResponse.getClusterName().value();