formatting

Author: valeriy42

x-pack/plugin/ml/qa/native-multi-node-tests/src/javaRestTest/java/org/elasticsearch/xpack/ml/integration/MlJobIT.java

@@ -544,9 +544,7 @@ public void testOutOfOrderData() throws Exception {
 
         Request flushRequest = new Request("POST", MachineLearning.BASE_PATH + "anomaly_detectors/" + jobId + "/_flush");
         flushRequest.setOptions(FLUSH_OPTIONS);
-        Response flushResponse = client().performRequest(
-            flushRequest
-        );
+        Response flushResponse = client().performRequest(flushRequest);
         assertThat(entityAsMap(flushResponse), hasEntry("flushed", true));
 
         closeJob(jobId);
@@ -586,9 +584,7 @@ public void testDeleteJob_TimingStatsDocumentIsDeleted() throws Exception {
 
         Request flushRequest = new Request("POST", MachineLearning.BASE_PATH + "anomaly_detectors/" + jobId + "/_flush");
         flushRequest.setOptions(FLUSH_OPTIONS);
-        Response flushResponse = client().performRequest(
-            flushRequest
-        );
+        Response flushResponse = client().performRequest(flushRequest);
         assertThat(entityAsMap(flushResponse), hasEntry("flushed", true));
 
         closeJob(jobId);

x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/rest/job/RestFlushJobAction.java

@@ -36,9 +36,7 @@ public class RestFlushJobAction extends BaseRestHandler {
     public List<Route> routes() {
         final String msg = "Forcing any buffered data to be processed is deprecated, "
             + "in a future major version it will be compulsory to use a datafeed";
-        return List.of(
-            Route.builder(POST, BASE_PATH + "anomaly_detectors/{" + ID + "}/_flush").deprecateAndKeep(msg).build()
-        );
+        return List.of(Route.builder(POST, BASE_PATH + "anomaly_detectors/{" + ID + "}/_flush").deprecateAndKeep(msg).build());
     }
 
     @Override

x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/rest/job/RestPostDataAction.java

@@ -8,7 +8,6 @@
 
 import org.elasticsearch.action.ActionListener;
 import org.elasticsearch.client.internal.node.NodeClient;
-import org.elasticsearch.core.UpdateForV9;
 import org.elasticsearch.rest.BaseRestHandler;
 import org.elasticsearch.rest.RestRequest;
 import org.elasticsearch.rest.RestStatus;
@@ -31,9 +30,7 @@ public class RestPostDataAction extends BaseRestHandler {
     public List<Route> routes() {
         final String msg = "Posting data directly to anomaly detection jobs is deprecated, "
             + "since version 7.11.0, in a future major version it will be compulsory to use a datafeed";
-        return List.of(
-            Route.builder(POST, BASE_PATH + "anomaly_detectors/{" + Job.ID + "}/_data").deprecateAndKeep(msg).build()
-        );
+        return List.of(Route.builder(POST, BASE_PATH + "anomaly_detectors/{" + Job.ID + "}/_data").deprecateAndKeep(msg).build());
     }
 
     @Override

x-pack/qa/rolling-upgrade/src/test/java/org/elasticsearch/upgrades/MlJobSnapshotUpgradeIT.java

@@ -346,8 +346,11 @@ protected void flushJob(String jobId) throws IOException {
             } else if (warnings.size() > 1) {
                 return true;
             }
-            return warnings.get(0).equals("Forcing any buffered data to be processed is deprecated, "
-                + "in a future major version it will be compulsory to use a datafeed") == false;
+            return warnings.get(0)
+                .equals(
+                    "Forcing any buffered data to be processed is deprecated, "
+                        + "in a future major version it will be compulsory to use a datafeed"
+                ) == false;
         }).build();
         Request flushRequest = new Request("POST", "/_ml/anomaly_detectors/" + jobId + "/_flush");
         flushRequest.setOptions(flushOptions);