Author: jbellis
Date: Sat Aug 13 06:11:33 2011
New Revision: 1157334
URL: http://svn.apache.org/viewvc?rev=1157334&view=rev
Log:
fix to SSTableSimpleUnsortedWriter bufferSize calculation
patch by Dave Brosius; reviewed by jbellis for CASSANDRA-3027
Modified:
cassandra/branches/cassandra-0.8/CHANGES.txt
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/io/sstable/SSTableSimpleUnsortedWriter.java
Modified: cassandra/branches/cassandra-0.8/CHANGES.txt
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1157334&r1=1157333&r2=1157334&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/CHANGES.txt (original)
+++ cassandra/branches/cassandra-0.8/CHANGES.txt Sat Aug 13 06:11:33 2011
@@ -6,6 +6,7 @@
* fix NPE when debug logging is enabled and dropped CF is present
in a commitlog segment (CASSANDRA-3021)
* fix cassandra.bat when CASSANDRA_HOME contains spaces (CASSANDRA-2952)
+ * fix to SSTableSimpleUnsortedWriter bufferSize calculation (CASSANDRA-3027)
0.8.4
Modified:
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/io/sstable/SSTableSimpleUnsortedWriter.java
URL:
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/io/sstable/SSTableSimpleUnsortedWriter.java?rev=1157334&r1=1157333&r2=1157334&view=diff
==============================================================================
---
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/io/sstable/SSTableSimpleUnsortedWriter.java
(original)
+++
cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/io/sstable/SSTableSimpleUnsortedWriter.java
Sat Aug 13 06:11:33 2011
@@ -63,7 +63,7 @@ public class SSTableSimpleUnsortedWriter
int bufferSizeInMB) throws IOException
{
super(directory, new CFMetaData(keyspace, columnFamily, subComparator
== null ? ColumnFamilyType.Standard : ColumnFamilyType.Super, comparator,
subComparator));
- this.bufferSize = bufferSizeInMB * 1024 * 1024;
+ this.bufferSize = bufferSizeInMB * 1024L * 1024L;
}
protected void writeRow(DecoratedKey key, ColumnFamily columnFamily)
throws IOException
