honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix failing line length checks 

Original commit: elastic/x-pack-elasticsearch@6a493a70a4
This commit is contained in:
David Kyle 2017-05-22 12:39:51 +01:00
parent 8e890d0365
commit 1873624a18
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
plugin/src/test/java/org/elasticsearch/license/MachineLearningLicensingTests.java
View File

@ -366,7 +366,8 @@ public class MachineLearningLicensingTests extends BaseMlIntegTestCase {
assertNotNull(putJobResponse); assertNotNull(putJobResponse);
PlainActionFuture<PutDatafeedAction.Response> putDatafeedListener = PlainActionFuture.newFuture(); PlainActionFuture<PutDatafeedAction.Response> putDatafeedListener = PlainActionFuture.newFuture();
new MachineLearningClient(client).putDatafeed( new MachineLearningClient(client).putDatafeed(
new PutDatafeedAction.Request(createDatafeed(datafeedId, jobId, Collections.singletonList(datafeedIndex))), putDatafeedListener); new PutDatafeedAction.Request(createDatafeed(datafeedId, jobId,
Collections.singletonList(datafeedIndex))), putDatafeedListener);
PutDatafeedAction.Response putDatafeedResponse = putDatafeedListener.actionGet(); PutDatafeedAction.Response putDatafeedResponse = putDatafeedListener.actionGet();
assertNotNull(putDatafeedResponse); assertNotNull(putDatafeedResponse);
PlainActionFuture<OpenJobAction.Response> openJobListener = PlainActionFuture.newFuture(); PlainActionFuture<OpenJobAction.Response> openJobListener = PlainActionFuture.newFuture();
@ -394,7 +395,8 @@ public class MachineLearningLicensingTests extends BaseMlIntegTestCase {
// the stop datafeed due to invalid license happens async, so check if the datafeed turns into stopped state: // the stop datafeed due to invalid license happens async, so check if the datafeed turns into stopped state:
assertBusy(() -> { assertBusy(() -> {
GetDatafeedsStatsAction.Response response = GetDatafeedsStatsAction.Response response =
new MachineLearningClient(client).getDatafeedsStats(new GetDatafeedsStatsAction.Request(datafeedId)).actionGet(); new MachineLearningClient(client)
.getDatafeedsStats(new GetDatafeedsStatsAction.Request(datafeedId)).actionGet();
assertEquals(DatafeedState.STOPPED, response.getResponse().results().get(0).getDatafeedState()); assertEquals(DatafeedState.STOPPED, response.getResponse().results().get(0).getDatafeedState());
}); });
} else { } else {
@ -482,7 +484,8 @@ public class MachineLearningLicensingTests extends BaseMlIntegTestCase {
assertNotNull(putJobResponse); assertNotNull(putJobResponse);
PlainActionFuture<PutDatafeedAction.Response> putDatafeedListener = PlainActionFuture.newFuture(); PlainActionFuture<PutDatafeedAction.Response> putDatafeedListener = PlainActionFuture.newFuture();
new MachineLearningClient(client).putDatafeed( new MachineLearningClient(client).putDatafeed(
new PutDatafeedAction.Request(createDatafeed(datafeedId, jobId, Collections.singletonList(jobId))), putDatafeedListener); new PutDatafeedAction.Request(createDatafeed(datafeedId, jobId,
Collections.singletonList(jobId))), putDatafeedListener);
PutDatafeedAction.Response putDatafeedResponse = putDatafeedListener.actionGet(); PutDatafeedAction.Response putDatafeedResponse = putDatafeedListener.actionGet();
assertNotNull(putDatafeedResponse); assertNotNull(putDatafeedResponse);
} }