# Any idea what these errors mean version 2.4.2 **URL:** \ **Category:** Elasticsearch\ **Created:** [January 5, 2017, 2:42pm UTC](https://discuss.elastic.co/t/any-idea-what-these-errors-mean-version-2-4-2/70690 "2017-01-05T14:42:49Z")\ **Posts on this page:** 9\ **Page:** 1
**Author:** ![genesis](https://avatars.discourse-cdn.com/v4/letter/g/96bed5/32.png) [@genesis](https://discuss.elastic.co/u/genesis)\ **Post date:** [January 5, 2017, 2:42pm UTC](https://discuss.elastic.co/t/any-idea-what-these-errors-mean-version-2-4-2/70690/1 "2017-01-05T14:42:49Z")
[27]: index [.marvel-es-1-2017.01.05], type [node], id [AVlvCMR8jzJUIDxT5zD3], message [RemoteTransportException[[ElasticSearch-28][10.10.0.133:9300][indices:data/write/bulk[s]]]; nested: RemoteTransportException[[ElasticSearch-28][10.10.0.133:9300][indices:data/write/bulk[s][p]]]; nested: EsRejectedExecutionException[rejected execution of org.elasticsearch.transport.TransportService$4@1d2e5bb4 on EsThreadPoolExecutor[bulk, queue capacity = 500, org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor@6eff5538[Running, pool size = 8, active threads = 8, queued tasks = 501, completed tasks = 7115945]]];] [29]: index [.marvel-es-1-2017.01.05], type [node], id [AVlvCMR8jzJUIDxT5zD4], message [RemoteTransportException[[ElasticSearch-28][10.10.0.133:9300][indices:data/write/bulk[s]]]; nested: RemoteTransportException[[ElasticSearch-28][10.10.0.133:9300][indices:data/write/bulk[s][p]]]; nested: EsRejectedExecutionException[rejected execution of org.elasticsearch.transport.TransportService$4@1d2e5bb4 on EsThreadPoolExecutor[bulk, queue capacity = 500, org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor@6eff5538[Running, pool size = 8, active threads = 8, queued tasks = 501, completed tasks = 7115945]]];] [31]: index [.marvel-es-1-2017.01.05], type [node], id [AVlvCMR8jzJUIDxT5zD5], message [RemoteTransportException[[ElasticSearch-28][10.10.0.133:9300][indices:data/write/bulk[s]]]; nested: RemoteTransportException[[ElasticSearch-28][10.10.0.133:9300][indices:data/write/bulk[s][p]]]; nested: EsRejectedExecutionException[rejected execution of org.elasticsearch.transport.TransportService$4@1d2e5bb4 on EsThreadPoolExecutor[bulk, queue capacity = 500, org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor@6eff5538[Running, pool size = 8, active threads = 8, queued tasks = 501, completed tasks = 7115945]]];] ---
**Author:** ![bender268](https://avatars.discourse-cdn.com/v4/letter/b/0ea827/32.png) [@bender268](https://discuss.elastic.co/u/bender268)\ **Post date:** [January 5, 2017, 2:47pm UTC](https://discuss.elastic.co/t/any-idea-what-these-errors-mean-version-2-4-2/70690/2 "2017-01-05T14:47:00Z")
I'm not sure, maybe it indicates, that you overflowed writing queue while mass inserting? EsThreadPoolExecutor[bulk, **queue capacity = 500,** org.elasticsearch.common.util.concurrent.EsThreadPoolExecutor@6eff5538[Running, pool size = 8, active threads = 8, **queued tasks = 501** , completed tasks = 7115945]]];] ---
**Author:** ![genesis](https://avatars.discourse-cdn.com/v4/letter/g/96bed5/32.png) [@genesis](https://discuss.elastic.co/u/genesis)\ **Post date:** [January 5, 2017, 2:51pm UTC](https://discuss.elastic.co/t/any-idea-what-these-errors-mean-version-2-4-2/70690/3 "2017-01-05T14:51:46Z")
Thanks for the quick response. Is it possible to increase the queue size? We have a 30 nodes cluster. Thanks ---
**Author:** ![bender268](https://avatars.discourse-cdn.com/v4/letter/b/0ea827/32.png) [@bender268](https://discuss.elastic.co/u/bender268)\ **Post date:** [January 5, 2017, 2:59pm UTC](https://discuss.elastic.co/t/any-idea-what-these-errors-mean-version-2-4-2/70690/4 "2017-01-05T14:59:53Z")
Try these settings. I suggest, you need the _bulk_ one [https://www.elastic.co/guide/en/elasticsearch/reference/2.4/modules-threadpool.html](https://www.elastic.co/guide/en/elasticsearch/reference/2.4/modules-threadpool.html) ---
**Author:** ![jasontedor](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/jasontedor/32/66992_2.png) [@jasontedor](https://discuss.elastic.co/u/jasontedor)\ **Post date:** [January 5, 2017, 3:04pm UTC](https://discuss.elastic.co/t/any-idea-what-these-errors-mean-version-2-4-2/70690/5 "2017-01-05T15:04:40Z")
It's possible to increase the queue size but let's talk about something here. Why is your queue filling up? Because your producers are adding work items to the queue faster than the consumers can take them off the queue. What would happen if you increase the queue size? The producers will still be producing at the rate they are currently producing, and the consumers will still be consuming at the rate they are currently consuming. This means that the queue will still fill up. Except now, the queue is bigger which will put more memory pressure on the system. In fact, this means the consumers might slow down, which might exacerbate the production rate greater than consumption rate problem. From there, a vicious feedback loop will form. Queues are helpful for handling variable load. They are not helpful for handing scenarios where the production rate exceeds the consumption rate. In this scenario, a queue filling up is a form of back pressure. It is telling you that you need to slow down the rate of production (or speed up the rate of consumption). Only increase the queue size if you are in a situation where you have variable load that sometimes exceeds capacity. Do not increase the queue size if you are in a situation where production rate exceeds consumption rate. ---
**Author:** ![genesis](https://avatars.discourse-cdn.com/v4/letter/g/96bed5/32.png) [@genesis](https://discuss.elastic.co/u/genesis)\ **Post date:** [January 5, 2017, 4:49pm UTC](https://discuss.elastic.co/t/any-idea-what-these-errors-mean-version-2-4-2/70690/6 "2017-01-05T16:49:16Z")
I am little confused with this definition: bulk For bulk operations. Thread pool type is fixed with a size of # of available processors, queue\_size of 50. I have 26 data nodes and 3 masters instance type: r3.2xlarge with 8 cores / each What do they mean by " Thread pool type is fixed with a size of # of available processors"? ---
**Author:** ![mikemccand](https://avatars.discourse-cdn.com/v4/letter/m/f04885/32.png) [@mikemccand](https://discuss.elastic.co/u/mikemccand)\ **Post date:** [January 5, 2017, 6:33pm UTC](https://discuss.elastic.co/t/any-idea-what-these-errors-mean-version-2-4-2/70690/7 "2017-01-05T18:33:36Z")
A fixed thread pool means it always has N (= number of CPU cores here) threads to execute tasks it pulls from the queue. Since each of your nodes has 8 cores, this means 8 threads per node for indexing ops. The queue handles the back log, holding onto new indexing requests until an indexing thread takes it. I agree with @jasontedor: you should not just blindly increase the queue size. You should understand which of the two possible root causes explain your rejected execution exceptions. Mike McCandless ---
**Author:** ![genesis](https://avatars.discourse-cdn.com/v4/letter/g/96bed5/32.png) [@genesis](https://discuss.elastic.co/u/genesis)\ **Post date:** [January 5, 2017, 6:35pm UTC](https://discuss.elastic.co/t/any-idea-what-these-errors-mean-version-2-4-2/70690/8 "2017-01-05T18:35:52Z")
Thank you all ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [February 2, 2017, 6:36pm UTC](https://discuss.elastic.co/t/any-idea-what-these-errors-mean-version-2-4-2/70690/9 "2017-02-02T18:36:08Z")
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.