diff --git a/core/src/test/java/org/elasticsearch/action/bulk/BulkProcessorRetryIT.java b/core/src/test/java/org/elasticsearch/action/bulk/BulkProcessorRetryIT.java index 3c38e2ef0fa..3fd32361215 100644 --- a/core/src/test/java/org/elasticsearch/action/bulk/BulkProcessorRetryIT.java +++ b/core/src/test/java/org/elasticsearch/action/bulk/BulkProcessorRetryIT.java @@ -54,7 +54,7 @@ public class BulkProcessorRetryIT extends ESIntegTestCase { //.put("threadpool.listener.queue_size", 1) .put("threadpool.get.queue_size", 1) // default is 50 - .put("threadpool.bulk.queue_size", 20) + .put("threadpool.bulk.queue_size", 30) .build(); }