This is an automated email from the ASF dual-hosted git repository.
jonmeredith pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/trunk by this push:
new 0a0e06847b
org.apache.cassandra.db.compaction.CompactionStrategyManagerBoundaryReloadTest.testReload
fails when running with TrieMemtables
0a0e06847b is described below
commit 0a0e06847bf10aa88a3a30c239c507a64f949d74
Author: Kamalesh Palanisamy <[email protected]>
AuthorDate: Fri Mar 3 15:42:06 2023 -0700
org.apache.cassandra.db.compaction.CompactionStrategyManagerBoundaryReloadTest.testReload
fails when running with TrieMemtables
patch by Kamalesh Palanisamy; reviewed by David Capwell, Jon Meredith for
CASSANDRA-18144
---
.../compaction/CompactionStrategyManagerBoundaryReloadTest.java | 8 ++------
1 file changed, 2 insertions(+), 6 deletions(-)
diff --git
a/test/unit/org/apache/cassandra/db/compaction/CompactionStrategyManagerBoundaryReloadTest.java
b/test/unit/org/apache/cassandra/db/compaction/CompactionStrategyManagerBoundaryReloadTest.java
index 1cecfead59..0d3b0d0e32 100644
---
a/test/unit/org/apache/cassandra/db/compaction/CompactionStrategyManagerBoundaryReloadTest.java
+++
b/test/unit/org/apache/cassandra/db/compaction/CompactionStrategyManagerBoundaryReloadTest.java
@@ -26,7 +26,6 @@ import org.junit.Test;
import org.apache.cassandra.cql3.CQLTester;
import org.apache.cassandra.db.ColumnFamilyStore;
import org.apache.cassandra.db.DiskBoundaries;
-import org.apache.cassandra.dht.ByteOrderedPartitioner;
import org.apache.cassandra.locator.InetAddressAndPort;
import org.apache.cassandra.locator.TokenMetadata;
import org.apache.cassandra.service.StorageService;
@@ -67,11 +66,8 @@ public class CompactionStrategyManagerBoundaryReloadTest
extends CQLTester
List<List<AbstractCompactionStrategy>> strategies =
cfs.getCompactionStrategyManager().getStrategies();
DiskBoundaries db = cfs.getDiskBoundaries();
TokenMetadata tmd = StorageService.instance.getTokenMetadata();
- byte[] tk1 = new byte[1], tk2 = new byte[1];
- tk1[0] = 2;
- tk2[0] = 1;
- tmd.updateNormalToken(new ByteOrderedPartitioner.BytesToken(tk1),
InetAddressAndPort.getByName("127.0.0.1"));
- tmd.updateNormalToken(new ByteOrderedPartitioner.BytesToken(tk2),
InetAddressAndPort.getByName("127.0.0.2"));
+ tmd.updateNormalToken(tmd.partitioner.getMinimumToken(),
InetAddressAndPort.getByName("127.0.0.1"));
+ tmd.updateNormalToken(tmd.partitioner.getMaximumToken(),
InetAddressAndPort.getByName("127.0.0.2"));
// make sure the strategy instances have been reloaded
assertFalse(isSame(strategies,
cfs.getCompactionStrategyManager().getStrategies()));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
