cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From alaksh...@apache.org
Subject svn commit: r758143 - /incubator/cassandra/trunk/src/org/apache/cassandra/db/Memtable.java
Date Wed, 25 Mar 2009 05:25:24 GMT
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



Mime
View raw message