sef

Author: original-brownbear

server/src/internalClusterTest/java/org/elasticsearch/action/search/TransportSearchIT.java

@@ -20,7 +20,6 @@
 import org.elasticsearch.action.index.IndexRequest;
 import org.elasticsearch.action.support.IndicesOptions;
 import org.elasticsearch.action.support.WriteRequest;
-import org.elasticsearch.client.internal.Client;
 import org.elasticsearch.cluster.metadata.IndexMetadata;
 import org.elasticsearch.common.Strings;
 import org.elasticsearch.common.breaker.CircuitBreaker;
@@ -445,84 +444,6 @@ public void testSearchIdle() throws Exception {
         );
     }
 
-    public void testCircuitBreakerReduceFail() throws Exception {
-        int numShards = randomIntBetween(1, 10);
-        indexSomeDocs("test", numShards, numShards * 3);
-
-        {
-            final AtomicArray<Boolean> responses = new AtomicArray<>(10);
-            final CountDownLatch latch = new CountDownLatch(10);
-            for (int i = 0; i < 10; i++) {
-                int batchReduceSize = randomIntBetween(2, Math.max(numShards + 1, 3));
-                SearchRequest request = prepareSearch("test").addAggregation(new TestAggregationBuilder("test"))
-                    .setBatchedReduceSize(batchReduceSize)
-                    .request();
-                final int index = i;
-                client().search(request, new ActionListener<>() {
-                    @Override
-                    public void onResponse(SearchResponse response) {
-                        responses.set(index, true);
-                        latch.countDown();
-                    }
-
-                    @Override
-                    public void onFailure(Exception e) {
-                        responses.set(index, false);
-                        latch.countDown();
-                    }
-                });
-            }
-            latch.await();
-            assertThat(responses.asList().size(), equalTo(10));
-            for (boolean resp : responses.asList()) {
-                assertTrue(resp);
-            }
-            assertBusy(() -> assertThat(requestBreakerUsed(), equalTo(0L)));
-        }
-
-        try {
-            updateClusterSettings(Settings.builder().put("indices.breaker.request.limit", "1b"));
-            final Client client = client();
-            assertBusy(() -> {
-                Exception exc = expectThrows(
-                    Exception.class,
-                    client.prepareSearch("test").addAggregation(new TestAggregationBuilder("test"))
-                );
-                assertThat(exc.getCause().getMessage(), containsString("<reduce_aggs>"));
-            });
-
-            final AtomicArray<Exception> exceptions = new AtomicArray<>(10);
-            final CountDownLatch latch = new CountDownLatch(10);
-            for (int i = 0; i < 10; i++) {
-                int batchReduceSize = randomIntBetween(2, Math.max(numShards + 1, 3));
-                SearchRequest request = prepareSearch("test").addAggregation(new TestAggregationBuilder("test"))
-                    .setBatchedReduceSize(batchReduceSize)
-                    .request();
-                final int index = i;
-                client().search(request, new ActionListener<>() {
-                    @Override
-                    public void onResponse(SearchResponse response) {
-                        latch.countDown();
-                    }
-
-                    @Override
-                    public void onFailure(Exception exc) {
-                        exceptions.set(index, exc);
-                        latch.countDown();
-                    }
-                });
-            }
-            latch.await();
-            assertThat(exceptions.asList().size(), equalTo(10));
-            for (Exception exc : exceptions.asList()) {
-                assertThat(exc.getCause().getMessage(), containsString("<reduce_aggs>"));
-            }
-            assertBusy(() -> assertThat(requestBreakerUsed(), equalTo(0L)));
-        } finally {
-            updateClusterSettings(Settings.builder().putNull("indices.breaker.request.limit"));
-        }
-    }
-
     public void testCircuitBreakerFetchFail() throws Exception {
         int numShards = randomIntBetween(1, 10);
         int numDocs = numShards * 10;