natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix the problem in CASSANDRA-9 JIRA 

git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@758143 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Avinash Lakshman 2009-03-25 05:25:23 +00:00
parent 82f5b6072a
commit af47dc8476
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/org/apache/cassandra/db/Memtable.java
View File

@ -261,8 +261,8 @@ public class Memtable implements MemtableMBean, Comparable<Memtable>
isFrozen_ = true; isFrozen_ = true;
/* Submit this Memtable to be flushed. */ /* Submit this Memtable to be flushed. */
Runnable flusher = new Flusher(cLogCtx); Runnable flusher = new Flusher(cLogCtx);
apartments_.get(cfName_).submit(flusher); apartments_.get(cfName_).submit(flusher);
// MemtableManager.instance().submit(cfStore.getColumnFamilyName(), this, cLogCtx); /* switch the memtable */
cfStore.switchMemtable(key, columnFamily, cLogCtx); cfStore.switchMemtable(key, columnFamily, cLogCtx);
} }
else else
@ -463,9 +463,7 @@ public class Memtable implements MemtableMBean, Comparable<Memtable>
default: default:
flushForRandomPartitioner(ssTable, cfStore, cLogCtx); flushForRandomPartitioner(ssTable, cfStore, cLogCtx);
break; break;
} }
columnFamilies_.clear();
} }
private void flushForRandomPartitioner(SSTable ssTable, ColumnFamilyStore cfStore, CommitLog.CommitLogContext cLogCtx) throws IOException private void flushForRandomPartitioner(SSTable ssTable, ColumnFamilyStore cfStore, CommitLog.CommitLogContext cLogCtx) throws IOException