Add system property to set the max number of native transport requests in queue
Patch by Jake Luciani; reviewed by Nate McCall for CASSANDRA-11363 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/6fb89b90 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/6fb89b90 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/6fb89b90 Branch: refs/heads/cassandra-3.9 Commit: 6fb89b905cf620200956fefa11c2dac8988a8837 Parents: 95b2d02 Author: Nate McCall <zznat...@gmail.com> Authored: Tue Sep 20 13:22:50 2016 +1200 Committer: Nate McCall <zznat...@gmail.com> Committed: Tue Sep 20 14:07:57 2016 +1200 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../org/apache/cassandra/transport/RequestThreadPoolExecutor.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/6fb89b90/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index c1c6c78..1438e98 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.1.16 + * Add system property to set the max number of native transport requests in queue (CASSANDRA-11363) * Include column family parameter when -st and -et are provided (CASSANDRA-11866) * Fix queries with empty ByteBuffer values in clustering column restrictions (CASSANDRA-12127) * Disable passing control to post-flush after flush failure to prevent data loss (CASSANDRA-11828) http://git-wip-us.apache.org/repos/asf/cassandra/blob/6fb89b90/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java b/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java index 9cac645..75b983a 100644 --- a/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java +++ b/src/java/org/apache/cassandra/transport/RequestThreadPoolExecutor.java @@ -30,7 +30,7 @@ import static org.apache.cassandra.concurrent.JMXEnabledSharedExecutorPool.SHARE public class RequestThreadPoolExecutor extends AbstractEventExecutor { - private final static int MAX_QUEUED_REQUESTS = 128; + private final static int MAX_QUEUED_REQUESTS = Integer.getInteger("cassandra.max_queued_native_transport_requests", 128); private final static String THREAD_FACTORY_ID = "Native-Transport-Requests"; private final TracingAwareExecutorService wrapped = SHARED.newExecutor(DatabaseDescriptor.getNativeTransportMaxThreads(), MAX_QUEUED_REQUESTS,
