You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2010/01/13 23:32:31 UTC
svn commit: r898979 -
/incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
Author: jbellis
Date: Wed Jan 13 22:32:31 2010
New Revision: 898979
URL: http://svn.apache.org/viewvc?rev=898979&view=rev
Log:
bump size of memtables-to-sort queue by one to give low-cpu systems a little more room. patch by jbellis
Modified:
incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
Modified: incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/db/ColumnFamilyStore.java?rev=898979&r1=898978&r2=898979&view=diff
==============================================================================
--- incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/db/ColumnFamilyStore.java (original)
+++ incubator/cassandra/branches/cassandra-0.5/src/java/org/apache/cassandra/db/ColumnFamilyStore.java Wed Jan 13 22:32:31 2010
@@ -85,7 +85,7 @@
Runtime.getRuntime().availableProcessors(),
Integer.MAX_VALUE,
TimeUnit.SECONDS,
- new LinkedBlockingQueue<Runnable>(2 * Runtime.getRuntime().availableProcessors()),
+ new LinkedBlockingQueue<Runnable>(1 + 2 * Runtime.getRuntime().availableProcessors()),
new NamedThreadFactory("FLUSH-SORTER-POOL"));
private static ExecutorService flushWriter_
= new DebuggableThreadPoolExecutor(DatabaseDescriptor.getAllDataFileLocations().length,