From 7666d3e5899222018a5f3df968cbee431e7ee342 Mon Sep 17 00:00:00 2001 From: David Kyle Date: Tue, 12 Jun 2018 12:52:46 +0100 Subject: [PATCH] Fix checkstyle --- .../xpack/ml/action/TransportStartDatafeedAction.java | 6 ++++-- .../xpack/ml/datafeed/MlRemoteLicenseCheckerTests.java | 3 ++- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/action/TransportStartDatafeedAction.java b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/action/TransportStartDatafeedAction.java index 113a1b59ccaf6..3d261864ab409 100644 --- a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/action/TransportStartDatafeedAction.java +++ b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/action/TransportStartDatafeedAction.java @@ -117,7 +117,8 @@ protected void masterOperation(StartDatafeedAction.Request request, ClusterState ActionListener> waitForTaskListener = new ActionListener>() { @Override - public void onResponse(PersistentTasksCustomMetaData.PersistentTask persistentTask) { + public void onResponse(PersistentTasksCustomMetaData.PersistentTask + persistentTask) { waitForDatafeedStarted(persistentTask.getId(), params, listener); } @@ -185,7 +186,8 @@ private void waitForDatafeedStarted(String taskId, StartDatafeedAction.DatafeedP persistentTasksService.waitForPersistentTaskCondition(taskId, predicate, params.getTimeout(), new PersistentTasksService.WaitForPersistentTaskListener() { @Override - public void onResponse(PersistentTasksCustomMetaData.PersistentTask persistentTask) { + public void onResponse(PersistentTasksCustomMetaData.PersistentTask + persistentTask) { if (predicate.exception != null) { // We want to return to the caller without leaving an unassigned persistent task, to match // what would have happened if the error had been detected in the "fast fail" validation diff --git a/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/datafeed/MlRemoteLicenseCheckerTests.java b/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/datafeed/MlRemoteLicenseCheckerTests.java index 263e10a603f36..47d4d30a7c6e4 100644 --- a/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/datafeed/MlRemoteLicenseCheckerTests.java +++ b/x-pack/plugin/ml/src/test/java/org/elasticsearch/xpack/ml/datafeed/MlRemoteLicenseCheckerTests.java @@ -161,7 +161,8 @@ public void onFailure(Exception e) { public void testBuildErrorMessage() { XPackInfoResponse.LicenseInfo platinumLicence = createPlatinumLicenseResponse(); - MlRemoteLicenseChecker.RemoteClusterLicenseInfo info = new MlRemoteLicenseChecker.RemoteClusterLicenseInfo("platinum-cluster", platinumLicence); + MlRemoteLicenseChecker.RemoteClusterLicenseInfo info = + new MlRemoteLicenseChecker.RemoteClusterLicenseInfo("platinum-cluster", platinumLicence); assertEquals(Strings.toString(platinumLicence), MlRemoteLicenseChecker.buildErrorMessage(info)); XPackInfoResponse.LicenseInfo basicLicense = createBasicLicenseResponse();