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);