EsRejectedExecutionException: rejected execution (queue capacity 1000)

Elastic Stack Elasticsearch
3

On Sat, 2014-08-09 at 23:53 -0700, Deep wrote:

Hi,

Elastic search internally has thread pool and a queue size is
associated with each pool. You can have pools for search threads,
index threads etc. Please see the Elasticsearch documentation in
link Elasticsearch Platform — Find real-time answers at scale | Elastic . I think it is possible to override these properties in the elasticsearch.yml configuration file.

Regards,
Ishwardeep

On Saturday, 9 August 2014 00:54:02 UTC+5:30, digit...@gmail.com
wrote:

    So I've seen a few posts on this, but I've not seen any
    solutions posted.  I've been log monitoring and I was trying
    to determine how to fix the below...any information would be
    great thank you. 
    
    [2014-08-08 19:14:12,578][DEBUG][action.search.type       ]
    [Jericho Drumm] [bro-201408032100][2],
    node[fgjxNK0cQ3O5Usn7wyjaMA], [P], s[STARTED]: Failed to
    execute
    [org.elasticsearch.action.search.SearchRequest@126067b7]
    lastShard [true]
    org.elasticsearch.common.util.concurrent.EsRejectedExecutionException: rejected execution (queue capacity 1000) on org.elasticsearch.search.action.SearchServiceTransportAction$23@5a879352
            at
    org.elasticsearch.common.util.concurrent.EsAbortPolicy.rejectedExecution(EsAbortPolicy.java:62)
            at
    java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:821)
            at
    java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1372)
            at
    org.elasticsearch.search.action.SearchServiceTransportAction.execute(SearchServiceTransportAction.java:509)
            at
    org.elasticsearch.search.action.SearchServiceTransportAction.sendExecuteQuery(SearchServiceTransportAction.java:203)
            at
    org.elasticsearch.action.search.type.TransportSearchQueryThenFetchAction$AsyncAction.sendExecuteFirstPhase(TransportSearchQueryThenFetchAction.java:80)
            at
    org.elasticsearch.action.search.type.TransportSearchTypeAction
    $BaseAsyncAction.performFirstPhase(TransportSearchTypeAction.java:171)
            at
    org.elasticsearch.action.search.type.TransportSearchTypeAction
    $BaseAsyncAction.start(TransportSearchTypeAction.java:153)
            at
    org.elasticsearch.action.search.type.TransportSearchQueryThenFetchAction.doExecute(TransportSearchQueryThenFetchAction.java:59)
            at
    org.elasticsearch.action.search.type.TransportSearchQueryThenFetchAction.doExecute(TransportSearchQueryThenFetchAction.java:49)
            at
    org.elasticsearch.action.support.TransportAction.execute(TransportAction.java:63)
            at
    org.elasticsearch.action.search.TransportSearchAction.doExecute(TransportSearchAction.java:101)
            at
    org.elasticsearch.action.search.TransportSearchAction.doExecute(TransportSearchAction.java:43)
            at
    org.elasticsearch.action.support.TransportAction.execute(TransportAction.java:63)
            at
    org.elasticsearch.client.node.NodeClient.execute(NodeClient.java:92)
            at
    org.elasticsearch.client.support.AbstractClient.search(AbstractClient.java:212)
            at
    org.elasticsearch.rest.action.search.RestSearchAction.handleRequest(RestSearchAction.java:75)
            at
    org.elasticsearch.rest.RestController.executeHandler(RestController.java:159)
            at
    org.elasticsearch.rest.RestController.dispatchRequest(RestController.java:142)
            at
    org.elasticsearch.http.HttpServer.internalDispatchRequest(HttpServer.java:121)
            at org.elasticsearch.http.HttpServer
    $Dispatcher.dispatchRequest(HttpServer.java:83)
            at
    org.elasticsearch.http.netty.NettyHttpServerTransport.dispatchRequest(NettyHttpServerTransport.java:294)
            at
    org.elasticsearch.http.netty.HttpRequestHandler.messageReceived(HttpRequestHandler.java:44)
            at
    org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
            at
    org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
            at
    org.elasticsearch.common.netty.channel.DefaultChannelPipeline
    $DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
            at
    org.elasticsearch.common.netty.handler.codec.http.HttpChunkAggregator.messageReceived(HttpChunkAggregator.java:145)
            at
    org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
            at
    org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
            at
    org.elasticsearch.common.netty.channel.DefaultChannelPipeline
    $DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
            at
    org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:296)
            at
    org.elasticsearch.common.netty.handler.codec.frame.FrameDecoder.unfoldAndFireMessageReceived(FrameDecoder.java:459)
            at
    org.elasticsearch.common.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:536)
            at
    org.elasticsearch.common.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
            at
    org.elasticsearch.common.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
            at
    org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
            at
    org.elasticsearch.common.netty.channel.DefaultChannelPipeline
    $DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
            at
    org.elasticsearch.common.netty.OpenChannelsHandler.handleUpstream(OpenChannelsHandler.java:74)
            at
    org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
            at
    org.elasticsearch.common.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:559)
            at
    org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:268)
            at
    org.elasticsearch.common.netty.channel.Channels.fireMessageReceived(Channels.java:255)
            at
    org.elasticsearch.common.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
            at
    org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
            at
    org.elasticsearch.common.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318)
            at
    org.elasticsearch.common.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
            at
    org.elasticsearch.common.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
            at
    org.elasticsearch.common.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
            at
    org.elasticsearch.common.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
            at
    java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
            at java.util.concurrent.ThreadPoolExecutor
    $Worker.run(ThreadPoolExecutor.java:615)
            at java.lang.Thread.run(Thread.java:745)

--
You received this message because you are subscribed to a topic in the
Google Groups "elasticsearch" group.
To unsubscribe from this topic, visit
https://groups.google.com/d/topic/elasticsearch/C6ZSpuEZspw/unsubscribe.
To unsubscribe from this group and all its topics, send an email to
elasticsearch+unsubscribe@googlegroups.com.
To view this discussion on the web visit
https://groups.google.com/d/msgid/elasticsearch/232cf97d-9289-4406-8a87-e2c0a39c2f0e%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

Thank you that helps.

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/1407675120.2783.1.camel%40JamesiMac.
For more options, visit https://groups.google.com/d/optout.