Author: jbellis
Date: Thu Feb 17 15:40:42 2011
New Revision: 1071649
URL: http://svn.apache.org/viewvc?rev=1071649&view=rev
Log:
fix #1255 for counters
Modified:
cassandra/trunk/src/java/org/apache/cassandra/db/CounterMutation.java
Modified: cassandra/trunk/src/java/org/apache/cassandra/db/CounterMutation.java
URL:
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/db/CounterMutation.java?rev=1071649&r1=1071648&r2=1071649&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/db/CounterMutation.java
(original)
+++ cassandra/trunk/src/java/org/apache/cassandra/db/CounterMutation.java Thu
Feb 17 15:40:42 2011
@@ -167,10 +167,12 @@ public class CounterMutation implements
// We need to transform all CounterUpdateColumn to CounterColumn and
we need to deepCopy. Both are done
// below since CUC.asCounterColumn() does a deep copy.
RowMutation rm = new RowMutation(rowMutation.getTable(),
ByteBufferUtil.clone(rowMutation.key()));
+ Table table = Table.open(rm.getTable());
for (ColumnFamily cf_ : rowMutation.getColumnFamilies())
{
ColumnFamily cf = cf_.cloneMeShallow();
+ ColumnFamilyStore cfs = table.getColumnFamilyStore(cf.id());
for (IColumn column : cf_.getColumnsMap().values())
{
cf.addColumn(column.localCopy(null)); // TODO fix this
