Reduce maxHintsInProgress patch by jbellis; reviewed by jasobrown for CASSANDRA-8415
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/773a38f7 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/773a38f7 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/773a38f7 Branch: refs/heads/trunk Commit: 773a38f79c30a0e270c46de7bc6430c835e5e995 Parents: 358f9f3 Author: Jonathan Ellis <[email protected]> Authored: Sat Dec 6 02:57:50 2014 +0000 Committer: Jonathan Ellis <[email protected]> Committed: Sat Dec 6 02:58:53 2014 +0000 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ src/java/org/apache/cassandra/service/StorageProxy.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/773a38f7/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 145347b..b007f31 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,6 @@ 2.1.3 + * Reduce maxHintsInProgress (CASSANDRA-8415) + * BTree updates may call provided update function twice (CASSANDRA-8018) * Release sstable references after anticompaction (CASSANDRA-8386) * Handle abort() in SSTableRewriter properly (CASSANDRA-8320) * Fix high size calculations for prepared statements (CASSANDRA-8231) http://git-wip-us.apache.org/repos/asf/cassandra/blob/773a38f7/src/java/org/apache/cassandra/service/StorageProxy.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java b/src/java/org/apache/cassandra/service/StorageProxy.java index d45e74b..5b413af 100644 --- a/src/java/org/apache/cassandra/service/StorageProxy.java +++ b/src/java/org/apache/cassandra/service/StorageProxy.java @@ -79,7 +79,7 @@ public class StorageProxy implements StorageProxyMBean public static final StorageProxy instance = new StorageProxy(); - private static volatile int maxHintsInProgress = 1024 * FBUtilities.getAvailableProcessors(); + private static volatile int maxHintsInProgress = 128 * FBUtilities.getAvailableProcessors(); private static final CacheLoader<InetAddress, AtomicInteger> hintsInProgress = new CacheLoader<InetAddress, AtomicInteger>() { public AtomicInteger load(InetAddress inetAddress)
