[
https://issues.apache.org/jira/browse/STORM-1569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15159375#comment-15159375
]
ASF GitHub Bot commented on STORM-1569:
---------------------------------------
GitHub user Parth-Brahmbhatt opened a pull request:
https://github.com/apache/storm/pull/1144
STORM-1569: Adding option in nimbus to specify request queue size in …
…config.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/Parth-Brahmbhatt/incubator-storm STORM-1569
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1144.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1144
----
commit 24a87af2c4a1aa6f03c0ccdabccde8ecb322bd99
Author: Parth Brahmbhatt <[email protected]>
Date: 2016-02-23T18:28:05Z
STORM-1569: Adding option in nimbus to specify request queue size in config.
----
> Allowing users to specify the nimbus thrift server queue size.
> --------------------------------------------------------------
>
> Key: STORM-1569
> URL: https://issues.apache.org/jira/browse/STORM-1569
> Project: Apache Storm
> Issue Type: Improvement
> Components: storm-core
> Affects Versions: 0.10.0
> Reporter: Parth Brahmbhatt
> Assignee: Parth Brahmbhatt
> Fix For: 1.0.0
>
>
> Currently the nimbus sever in secure mode uses
> https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ThreadPoolExecutor.html
> Backed by
> https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/SynchronousQueue.html,
> Please see
> https://github.com/apache/thrift/blob/0.9.2/lib/java/src/org/apache/thrift/server/TThreadPoolServer.java#L132.
> This means that if all executor threads are busy serving a request and new
> requests come in we will see RejectedExecutionExceptions in logs once they
> have reached the retry limit. Instead we should allow the requests to be
> queued. This patch allows the requests to be queued by replacing
> SynchronousQueue with
> https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ArrayBlockingQueue.html
> with default size of 100000 requests which should be large enough for most
> applications. Applications can modify this default by adding the config
> nimbus.queue.size to their storm.yaml and bouncing nimbus.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
