honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 18:35:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

[TEST] Call get on update job action from DetectionRulesIT

Browse Source 
This was the reason for the intermittent failures of this test.

Original commit: elastic/x-pack-elasticsearch@e8605590a1
This commit is contained in:
Dimitrios Athanasiou 2017-04-19 19:51:17 +01:00
parent e2cc00ab8e
commit a0099cace6
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
plugin/src/test/java/org/elasticsearch/xpack/ml/integration/DetectionRulesIT.java
View File

@ -73,7 +73,7 @@ public class DetectionRulesIT extends MlNativeAutodetectIntegTestCase {
Arrays.asList(detector.build())); Arrays.asList(detector.build()));
analysisConfig.setBucketSpan(TimeValue.timeValueHours(1)); analysisConfig.setBucketSpan(TimeValue.timeValueHours(1));
DataDescription.Builder dataDescription = new DataDescription.Builder(); DataDescription.Builder dataDescription = new DataDescription.Builder();
Job.Builder job = new Job.Builder("detectrion-rule-numeric-test"); Job.Builder job = new Job.Builder("detection-rule-numeric-test");
job.setAnalysisConfig(analysisConfig); job.setAnalysisConfig(analysisConfig);
job.setDataDescription(dataDescription); job.setDataDescription(dataDescription);

2
plugin/src/test/java/org/elasticsearch/xpack/ml/integration/MlNativeAutodetectIntegTestCase.java
View File

@ -128,7 +128,7 @@ abstract class MlNativeAutodetectIntegTestCase extends SecurityIntegTestCase {
protected void updateJob(String jobId, JobUpdate update) throws Exception { protected void updateJob(String jobId, JobUpdate update) throws Exception {
UpdateJobAction.Request request = new UpdateJobAction.Request(jobId, update); UpdateJobAction.Request request = new UpdateJobAction.Request(jobId, update);
client().execute(UpdateJobAction.INSTANCE, request); client().execute(UpdateJobAction.INSTANCE, request).get();
} }
protected void deleteJob(String jobId) throws Exception { protected void deleteJob(String jobId) throws Exception {