diff --git a/test/unit/org/apache/cassandra/db/RangeTombstoneListTest.java b/test/unit/org/apache/cassandra/db/RangeTombstoneListTest.java index 92a0b4a90b..7dc86dae44 100644 --- a/test/unit/org/apache/cassandra/db/RangeTombstoneListTest.java +++ b/test/unit/org/apache/cassandra/db/RangeTombstoneListTest.java @@ -195,12 +195,6 @@ public class RangeTombstoneListTest @Test public void addAllTest() - { - //addAllTest(false); - addAllTest(true); - } - - private void addAllTest(boolean doMerge) { RangeTombstoneList l1 = new RangeTombstoneList(cmp, 0); l1.add(rt(0, 4, 5)); diff --git a/test/unit/org/apache/cassandra/locator/OldNetworkTopologyStrategyTest.java b/test/unit/org/apache/cassandra/locator/OldNetworkTopologyStrategyTest.java index a11a128c57..c7470f8c1d 100644 --- a/test/unit/org/apache/cassandra/locator/OldNetworkTopologyStrategyTest.java +++ b/test/unit/org/apache/cassandra/locator/OldNetworkTopologyStrategyTest.java @@ -181,7 +181,7 @@ public class OldNetworkTopologyStrategyTest extends SchemaLoader BigIntegerToken newToken = new BigIntegerToken("21267647932558653966460912964485513216"); BigIntegerToken[] tokens = initTokens(); BigIntegerToken[] tokensAfterMove = initTokensAfterMove(tokens, movingNodeIdx, newToken); - Pair>, Set>> ranges = calculateStreamAndFetchRanges(tokens, tokensAfterMove, movingNodeIdx, newToken); + Pair>, Set>> ranges = calculateStreamAndFetchRanges(tokens, tokensAfterMove, movingNodeIdx); assertEquals(ranges.left.iterator().next().left, tokensAfterMove[movingNodeIdx]); assertEquals(ranges.left.iterator().next().right, tokens[movingNodeIdx]); @@ -198,7 +198,7 @@ public class OldNetworkTopologyStrategyTest extends SchemaLoader BigIntegerToken newToken = new BigIntegerToken("35267647932558653966460912964485513216"); BigIntegerToken[] tokens = initTokens(); BigIntegerToken[] tokensAfterMove = initTokensAfterMove(tokens, movingNodeIdx, newToken); - Pair>, Set>> ranges = calculateStreamAndFetchRanges(tokens, tokensAfterMove, movingNodeIdx, newToken); + Pair>, Set>> ranges = calculateStreamAndFetchRanges(tokens, tokensAfterMove, movingNodeIdx); assertEquals("No data should be streamed", ranges.left.size(), 0); assertEquals(ranges.right.iterator().next().left, tokens[movingNodeIdx]); @@ -216,7 +216,7 @@ public class OldNetworkTopologyStrategyTest extends SchemaLoader BigIntegerToken newToken = new BigIntegerToken("90070591730234615865843651857942052864"); BigIntegerToken[] tokens = initTokens(); BigIntegerToken[] tokensAfterMove = initTokensAfterMove(tokens, movingNodeIdx, newToken); - Pair>, Set>> ranges = calculateStreamAndFetchRanges(tokens, tokensAfterMove, movingNodeIdx, newToken); + Pair>, Set>> ranges = calculateStreamAndFetchRanges(tokens, tokensAfterMove, movingNodeIdx); // sort the results, so they can be compared Range[] toStream = ranges.left.toArray(new Range[0]); @@ -248,7 +248,7 @@ public class OldNetworkTopologyStrategyTest extends SchemaLoader BigIntegerToken newToken = new BigIntegerToken("52535295865117307932921825928971026432"); BigIntegerToken[] tokens = initTokens(); BigIntegerToken[] tokensAfterMove = initTokensAfterMove(tokens, movingNodeIdx, newToken); - Pair>, Set>> ranges = calculateStreamAndFetchRanges(tokens, tokensAfterMove, movingNodeIdx, newToken); + Pair>, Set>> ranges = calculateStreamAndFetchRanges(tokens, tokensAfterMove, movingNodeIdx); // sort the results, so they can be compared @@ -280,7 +280,7 @@ public class OldNetworkTopologyStrategyTest extends SchemaLoader BigIntegerToken newToken = new BigIntegerToken("158873535527910577765226390751398592512"); BigIntegerToken[] tokens = initTokens(); BigIntegerToken[] tokensAfterMove = initTokensAfterMove(tokens, movingNodeIdx, newToken); - Pair>, Set>> ranges = calculateStreamAndFetchRanges(tokens, tokensAfterMove, movingNodeIdx, newToken); + Pair>, Set>> ranges = calculateStreamAndFetchRanges(tokens, tokensAfterMove, movingNodeIdx); Range[] toStream = ranges.left.toArray(new Range[0]); Range[] toFetch = ranges.right.toArray(new Range[0]); @@ -350,7 +350,7 @@ public class OldNetworkTopologyStrategyTest extends SchemaLoader } - private Pair>, Set>> calculateStreamAndFetchRanges(BigIntegerToken[] tokens, BigIntegerToken[] tokensAfterMove, int movingNodeIdx, BigIntegerToken newToken) throws UnknownHostException + private Pair>, Set>> calculateStreamAndFetchRanges(BigIntegerToken[] tokens, BigIntegerToken[] tokensAfterMove, int movingNodeIdx) throws UnknownHostException { RackInferringSnitch endpointSnitch = new RackInferringSnitch(); diff --git a/tools/stress/src/org/apache/cassandra/stress/generatedata/DataGenStringDictionary.java b/tools/stress/src/org/apache/cassandra/stress/generatedata/DataGenStringDictionary.java index 7733ed6889..59079560d0 100644 --- a/tools/stress/src/org/apache/cassandra/stress/generatedata/DataGenStringDictionary.java +++ b/tools/stress/src/org/apache/cassandra/stress/generatedata/DataGenStringDictionary.java @@ -27,17 +27,17 @@ public class DataGenStringDictionary extends DataGen @Override public void generate(ByteBuffer fill, long index, ByteBuffer seed) { - fill(fill, 0); + fill(fill); } @Override public void generate(List fills, long index, ByteBuffer seed) { for (int i = 0 ; i < fills.size() ; i++) - fill(fills.get(0), i); + fill(fills.get(0)); } - private void fill(ByteBuffer fill, int column) + private void fill(ByteBuffer fill) { fill.clear(); byte[] trg = fill.array();