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 elastic search documentation in > link > http://www.elasticsearch.org/guide/en/elasticsearch/reference/current/modules-threadpool.html > . 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+unsubscr...@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+unsubscr...@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.
