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 2009/08/27 05:13:50 UTC

svn commit: r808268 - /incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java

Author: jbellis
Date: Thu Aug 27 03:13:50 2009
New Revision: 808268

URL: http://svn.apache.org/viewvc?rev=808268&view=rev
Log:
fix unit test.  patch by jbellis for CASSANDRA-242

Modified:
    incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java

Modified: incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java?rev=808268&r1=808267&r2=808268&view=diff
==============================================================================
--- incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java (original)
+++ incubator/cassandra/trunk/test/unit/org/apache/cassandra/db/BootstrapTest.java Thu Aug 27 03:13:50 2009
@@ -31,6 +31,8 @@
 import org.apache.cassandra.db.filter.QueryPath;
 import org.apache.cassandra.dht.Range;
 import org.apache.cassandra.dht.StringToken;
+import org.apache.cassandra.dht.BytesToken;
+import org.apache.cassandra.dht.CollatingOrderPreservingPartitioner;
 import org.apache.cassandra.net.EndPoint;
 import org.apache.cassandra.net.io.StreamContextManager;
 import org.junit.Test;
@@ -45,7 +47,6 @@
     {
         Table table = Table.open("Keyspace1");
         ColumnFamilyStore store = table.getColumnFamilyStore(columnFamilyName);
-
        
         for (int j = 0; j < insertsPerTable; j++) 
         {
@@ -58,7 +59,7 @@
         store.forceBlockingFlush();
         List<String> fileList = new ArrayList<String>();
         List<Range> ranges  = new ArrayList<Range>();
-        Range r = new Range(new StringToken("0"), new StringToken("zzzzzz"));
+        Range r = new Range(CollatingOrderPreservingPartitioner.MINIMUM, new BytesToken("zzzzzz".getBytes()));
         ranges.add(r);
 
         boolean result = store.doAntiCompaction(ranges, new EndPoint("127.0.0.1", 9150), fileList);