You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by al...@apache.org on 2009/03/25 06:25:24 UTC
svn commit: r758143 -
/incubator/cassandra/trunk/src/org/apache/cassandra/db/Memtable.java
Author: alakshman
Date: Wed Mar 25 05:25:23 2009
New Revision: 758143
URL: http://svn.apache.org/viewvc?rev=758143&view=rev
Log:
Fix the problem in CASSANDRA-9 JIRA
Modified:
incubator/cassandra/trunk/src/org/apache/cassandra/db/Memtable.java
Modified: incubator/cassandra/trunk/src/org/apache/cassandra/db/Memtable.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/db/Memtable.java?rev=758143&r1=758142&r2=758143&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/org/apache/cassandra/db/Memtable.java (original)
+++ incubator/cassandra/trunk/src/org/apache/cassandra/db/Memtable.java Wed Mar 25 05:25:23 2009
@@ -261,8 +261,8 @@
isFrozen_ = true;
/* Submit this Memtable to be flushed. */
Runnable flusher = new Flusher(cLogCtx);
- apartments_.get(cfName_).submit(flusher);
- // MemtableManager.instance().submit(cfStore.getColumnFamilyName(), this, cLogCtx);
+ apartments_.get(cfName_).submit(flusher);
+ /* switch the memtable */
cfStore.switchMemtable(key, columnFamily, cLogCtx);
}
else
@@ -463,9 +463,7 @@
default:
flushForRandomPartitioner(ssTable, cfStore, cLogCtx);
break;
- }
-
- columnFamilies_.clear();
+ }
}
private void flushForRandomPartitioner(SSTable ssTable, ColumnFamilyStore cfStore, CommitLog.CommitLogContext cLogCtx) throws IOException