From eb6d11d54932ea929e983d3f986314e1e3ef0d33 Mon Sep 17 00:00:00 2001 From: Jonathan Ellis Date: Thu, 27 Aug 2009 03:13:50 +0000 Subject: [PATCH] fix unit test. patch by jbellis for CASSANDRA-242 git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@808268 13f79535-47bb-0310-9956-ffa450edef68 --- test/unit/org/apache/cassandra/db/BootstrapTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/test/unit/org/apache/cassandra/db/BootstrapTest.java b/test/unit/org/apache/cassandra/db/BootstrapTest.java index 66ba27e718..ff17e4a178 100644 --- a/test/unit/org/apache/cassandra/db/BootstrapTest.java +++ b/test/unit/org/apache/cassandra/db/BootstrapTest.java @@ -31,6 +31,8 @@ import java.util.concurrent.ExecutionException; 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 @@ public class BootstrapTest { Table table = Table.open("Keyspace1"); ColumnFamilyStore store = table.getColumnFamilyStore(columnFamilyName); - for (int j = 0; j < insertsPerTable; j++) { @@ -58,7 +59,7 @@ public class BootstrapTest store.forceBlockingFlush(); List fileList = new ArrayList(); List ranges = new ArrayList(); - 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);