|
21 | 21 | import org.elasticsearch.client.RestClientBuilder; |
22 | 22 | import org.elasticsearch.common.Strings; |
23 | 23 | import org.elasticsearch.common.logging.HeaderWarning; |
24 | | -import org.elasticsearch.common.logging.LoggerMessageFormat; |
25 | 24 | import org.elasticsearch.common.settings.Setting; |
26 | 25 | import org.elasticsearch.common.settings.Settings; |
27 | 26 | import org.elasticsearch.core.RestApiVersion; |
|
55 | 54 | import static org.elasticsearch.xpack.deprecation.DeprecationSettings.TEST_NOT_DEPRECATED_SETTING; |
56 | 55 | import static org.hamcrest.Matchers.allOf; |
57 | 56 | import static org.hamcrest.Matchers.containsInAnyOrder; |
58 | | -import static org.hamcrest.Matchers.containsString; |
59 | 57 | import static org.hamcrest.Matchers.equalTo; |
60 | 58 | import static org.hamcrest.Matchers.everyItem; |
61 | 59 | import static org.hamcrest.Matchers.hasEntry; |
@@ -176,46 +174,6 @@ private Response cleanupSettings() throws IOException { |
176 | 174 | return performScopedRequest(request, xOpaqueId() + "-cleanup"); |
177 | 175 | } |
178 | 176 |
|
179 | | - /** |
180 | | - * Attempts to do a scatter/gather request that expects unique responses per sub-request. |
181 | | - */ |
182 | | - public void testUniqueDeprecationResponsesMergedTogether() throws IOException { |
183 | | - final String[] indices = new String[randomIntBetween(2, 5)]; |
184 | | - |
185 | | - // add at least one document for each index |
186 | | - for (int i = 0; i < indices.length; ++i) { |
187 | | - indices[i] = "test" + i; |
188 | | - |
189 | | - // create indices with a single shard to reduce noise; the query only deprecates uniquely by index anyway |
190 | | - createIndex(indices[i], Settings.builder().put("number_of_shards", 1).build()); |
191 | | - |
192 | | - int randomDocCount = randomIntBetween(1, 2); |
193 | | - |
194 | | - for (int j = 0; j < randomDocCount; j++) { |
195 | | - final Request request = new Request("PUT", indices[i] + "/" + j); |
196 | | - request.setJsonEntity("{ \"field\": " + j + " }"); |
197 | | - performScopedRequest(request); |
198 | | - } |
199 | | - } |
200 | | - |
201 | | - final String commaSeparatedIndices = String.join(",", indices); |
202 | | - |
203 | | - performScopedRequest(new Request("POST", commaSeparatedIndices + "/_refresh")); |
204 | | - // trigger all index deprecations |
205 | | - Request request = new Request("GET", "/" + commaSeparatedIndices + "/_search"); |
206 | | - request.setJsonEntity("{ \"query\": { \"bool\": { \"filter\": [ { \"deprecated\": {} } ] } } }"); |
207 | | - Response response = performScopedRequest(request); |
208 | | - |
209 | | - final List<String> deprecatedWarnings = getWarningHeaders(response.getHeaders()); |
210 | | - final List<Matcher<? super String>> headerMatchers = new ArrayList<>(); |
211 | | - |
212 | | - for (String index : indices) { |
213 | | - headerMatchers.add(containsString(LoggerMessageFormat.format("[{}] index", (Object) index))); |
214 | | - } |
215 | | - |
216 | | - assertThat(deprecatedWarnings, containsInAnyOrder(headerMatchers)); |
217 | | - } |
218 | | - |
219 | 177 | public void testDeprecationWarningsAppearInHeaders() throws Exception { |
220 | 178 | doTestDeprecationWarningsAppearInHeaders(xOpaqueId()); |
221 | 179 | } |
|
0 commit comments