You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2010/12/12 04:22:33 UTC
svn commit: r1044761 -
/cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java
Author: jbellis
Date: Sun Dec 12 03:22:33 2010
New Revision: 1044761
URL: http://svn.apache.org/viewvc?rev=1044761&view=rev
Log:
copy Text bytes because it gets re-used
patch by jbellis; tested by Jeremy Hanna for CASSANDRA-1842
Modified:
cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java
Modified: cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java?rev=1044761&r1=1044760&r2=1044761&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java (original)
+++ cassandra/branches/cassandra-0.7/contrib/word_count/src/WordCount.java Sun Dec 12 03:22:33 2010
@@ -134,7 +134,8 @@ public class WordCount extends Configure
private static Mutation getMutation(Text word, int sum)
{
Column c = new Column();
- c.name = ByteBuffer.wrap(word.getBytes());
+ byte[] wordBytes = word.getBytes();
+ c.name = ByteBuffer.wrap(Arrays.copyOf(wordBytes, wordBytes.length));
c.value = ByteBuffer.wrap(String.valueOf(sum).getBytes());
c.timestamp = System.currentTimeMillis() * 1000;