From c7e977701a249e5f72b18c9380e05efce449814c Mon Sep 17 00:00:00 2001 From: Dan Hermann <danhermann@users.noreply.github.com> Date: Thu, 9 Jul 2020 13:12:04 -0500 Subject: [PATCH] Data stream support for async search --- .../10_data_stream_resolvability.yml | 71 +++++++++++++++++++ 1 file changed, 71 insertions(+) diff --git a/x-pack/plugin/src/test/resources/rest-api-spec/test/data_stream/10_data_stream_resolvability.yml b/x-pack/plugin/src/test/resources/rest-api-spec/test/data_stream/10_data_stream_resolvability.yml index aabcbb205ba7a..6007c062bac55 100644 --- a/x-pack/plugin/src/test/resources/rest-api-spec/test/data_stream/10_data_stream_resolvability.yml +++ b/x-pack/plugin/src/test/resources/rest-api-spec/test/data_stream/10_data_stream_resolvability.yml @@ -338,3 +338,74 @@ indices.delete_data_stream: name: simple-data-stream1 - is_true: acknowledged + +--- +"Verify data stream resolvability in async search": + - skip: + version: " - 7.99.99" + reason: "change to 7.8.99 after backport" + features: allowed_warnings + + - do: + allowed_warnings: + - "index template [my-template1] has index patterns [simple-data-stream1] matching patterns from existing older templates [global] with patterns (global => [*]); this template [my-template1] will take precedence during new index creation" + indices.put_index_template: + name: my-template1 + body: + index_patterns: [simple-data-stream1] + template: + mappings: + properties: + '@timestamp': + type: date + data_stream: + timestamp_field: '@timestamp' + + - do: + indices.create_data_stream: + name: simple-data-stream1 + - is_true: acknowledged + + - do: + index: + index: simple-data-stream1 + body: { max: 2 } + + - do: + index: + index: simple-data-stream1 + body: { max: 1 } + + - do: + index: + index: simple-data-stream1 + body: { max: 3 } + + - do: + indices.refresh: + index: simple-data-stream1 + + - do: + async_search.submit: + index: simple-data-stream1 + batched_reduce_size: 2 + wait_for_completion_timeout: 10s + body: + query: + match_all: {} + aggs: + max: + max: + field: max + sort: max + + - is_false: id + - match: { is_partial: false } + - length: { response.hits.hits: 3 } + - match: { response.hits.hits.0._source.max: 1 } + - match: { response.aggregations.max.value: 3.0 } + + - do: + indices.delete_data_stream: + name: simple-data-stream1 + - is_true: acknowledged