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

[TEST] use unique job ids to make debugging log files easier 

Original commit: elastic/x-pack-elasticsearch@9f04e1b01f
This commit is contained in:
Martijn van Groningen 2017-01-24 11:59:49 +01:00
parent 29451bb7e3
commit 8dbaef186e
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
elasticsearch/src/test/java/org/elasticsearch/xpack/ml/action/DatafeedJobsIT.java
View File

@ -81,7 +81,7 @@ public class DatafeedJobsIT extends ESIntegTestCase {
long numDocs2 = randomIntBetween(32, 2048);
indexDocs("data-2", numDocs2, oneWeekAgo, now);
Job.Builder job = createJob();
Job.Builder job = createJob("lookback-job");
PutJobAction.Request putJobRequest = new PutJobAction.Request(job.build(true, job.getId()));
PutJobAction.Response putJobResponse = client().execute(PutJobAction.INSTANCE, putJobRequest).get();
assertTrue(putJobResponse.isAcknowledged());
@ -122,7 +122,7 @@ public class DatafeedJobsIT extends ESIntegTestCase {
long lastWeek = now - 604800000;
indexDocs("data", numDocs1, lastWeek, now);
Job.Builder job = createJob();
Job.Builder job = createJob("realtime-job");
PutJobAction.Request putJobRequest = new PutJobAction.Request(job.build(true, job.getId()));
PutJobAction.Response putJobResponse = client().execute(PutJobAction.INSTANCE, putJobRequest).get();
assertTrue(putJobResponse.isAcknowledged());
@ -193,7 +193,7 @@ public class DatafeedJobsIT extends ESIntegTestCase {
logger.info("Indexed [{}] documents", numDocs);
}
private Job.Builder createJob() {
private Job.Builder createJob(String jobId) {
DataDescription.Builder dataDescription = new DataDescription.Builder();
dataDescription.setFormat(DataDescription.DataFormat.JSON);
dataDescription.setTimeFormat("yyyy-MM-dd HH:mm:ss");
@ -202,7 +202,7 @@ public class DatafeedJobsIT extends ESIntegTestCase {
AnalysisConfig.Builder analysisConfig = new AnalysisConfig.Builder(Collections.singletonList(d.build()));
Job.Builder builder = new Job.Builder();
builder.setId("my_job_id");
builder.setId(jobId);
builder.setAnalysisConfig(analysisConfig);
builder.setDataDescription(dataDescription);