diff --git a/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/mixed_cluster/30_ml_jobs_crud.yml b/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/mixed_cluster/30_ml_jobs_crud.yml index a3348de2c5d..92268391fae 100644 --- a/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/mixed_cluster/30_ml_jobs_crud.yml +++ b/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/mixed_cluster/30_ml_jobs_crud.yml @@ -35,6 +35,19 @@ job_id: old-cluster-job - match: { count: 1 } +--- +"Test get old cluster job's timing stats": + - skip: + version: " - 7.2.99" + reason: timing_stats was introduced in 7.3.0 + - do: + ml.get_job_stats: + job_id: old-cluster-job-with-ts + - match: { jobs.0.job_id: old-cluster-job-with-ts } + - match: { jobs.0.state: "closed" } + - match: { jobs.0.timing_stats.job_id: old-cluster-job-with-ts } + - gte: { jobs.0.timing_stats.bucket_count: 0 } + --- "Test get old cluster categorization job": - do: diff --git a/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/old_cluster/30_ml_jobs_crud.yml b/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/old_cluster/30_ml_jobs_crud.yml index db9092e57e2..4d3d364366d 100644 --- a/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/old_cluster/30_ml_jobs_crud.yml +++ b/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/old_cluster/30_ml_jobs_crud.yml @@ -169,6 +169,64 @@ index: [".ml-state", ".ml-anomalies-shared"] wait_for_status: green +--- +"Put job with timing stats checking on the old cluster and post some data": + + - do: + ml.put_job: + job_id: old-cluster-job-with-ts + body: > + { + "description":"Cluster upgrade with timing stats checking", + "analysis_config" : { + "bucket_span": "60s", + "detectors" :[{"function":"metric","field_name":"responsetime","by_field_name":"airline"}] + }, + "analysis_limits" : { + "model_memory_limit": "50mb" + }, + "data_description" : { + "format":"xcontent", + "time_field":"time", + "time_format":"epoch" + } + } + - match: { job_id: old-cluster-job-with-ts } + + - do: + ml.open_job: + job_id: old-cluster-job-with-ts + + - do: + ml.post_data: + job_id: old-cluster-job-with-ts + body: + - airline: AAL + responsetime: 132.2046 + sourcetype: post-data-job + time: 1403481600 + - airline: JZA + responsetime: 990.4628 + sourcetype: post-data-job + time: 1403481700 + - match: { processed_record_count: 2 } + + - do: + ml.close_job: + job_id: old-cluster-job-with-ts + + - do: + ml.get_buckets: + job_id: old-cluster-job-with-ts + - match: { count: 1 } + + # Wait for indices to be fully allocated before + # killing the node + - do: + cluster.health: + index: [".ml-state", ".ml-anomalies-shared"] + wait_for_status: green + --- "Put job with empty strings in the configuration": - do: diff --git a/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/upgraded_cluster/30_ml_jobs_crud.yml b/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/upgraded_cluster/30_ml_jobs_crud.yml index 8d38cdd1570..801738d1ae1 100644 --- a/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/upgraded_cluster/30_ml_jobs_crud.yml +++ b/x-pack/qa/rolling-upgrade/src/test/resources/rest-api-spec/test/upgraded_cluster/30_ml_jobs_crud.yml @@ -109,6 +109,26 @@ setup: name: ".ml-state-write" - is_true: '' +--- +"Test get old cluster job's timing stats": + - do: + ml.get_job_stats: + job_id: old-cluster-job-with-ts + - match: { jobs.0.job_id: old-cluster-job-with-ts } + - match: { jobs.0.state: "closed" } + - match: { jobs.0.timing_stats.job_id: old-cluster-job-with-ts } + - gte: { jobs.0.timing_stats.bucket_count: 0 } + + - do: + ml.delete_job: + job_id: old-cluster-job-with-ts + - match: { acknowledged: true } + + - do: + catch: missing + ml.get_jobs: + job_id: old-cluster-job-with-ts + --- "Test job with pre 6.4 rules":