You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by aw...@apache.org on 2022/12/09 20:01:41 UTC
[cassandra] 03/05: post-rebase fix to AccordIntegrationTest
This is an automated email from the ASF dual-hosted git repository.
aweisberg pushed a commit to branch cas-accord-v2
in repository https://gitbox.apache.org/repos/asf/cassandra.git
commit 1c8f38796c35aa75cda755f732494c6156c6887c
Author: Caleb Rackliffe <ca...@gmail.com>
AuthorDate: Tue Dec 6 14:26:25 2022 -0600
post-rebase fix to AccordIntegrationTest
---
.../cassandra/distributed/test/accord/AccordIntegrationTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/test/distributed/org/apache/cassandra/distributed/test/accord/AccordIntegrationTest.java b/test/distributed/org/apache/cassandra/distributed/test/accord/AccordIntegrationTest.java
index d8ad1ec6e1..b26f549516 100644
--- a/test/distributed/org/apache/cassandra/distributed/test/accord/AccordIntegrationTest.java
+++ b/test/distributed/org/apache/cassandra/distributed/test/accord/AccordIntegrationTest.java
@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import accord.messages.Commit;
-import accord.primitives.Keys;
+import accord.primitives.Unseekables;
import accord.topology.Topologies;
import org.apache.cassandra.dht.Murmur3Partitioner;
import org.apache.cassandra.distributed.api.ConsistencyLevel;
@@ -121,7 +121,7 @@ public class AccordIntegrationTest extends AccordTestBase
at accord.messages.PreAccept.process(PreAccept.java:90)
at accord.messages.TxnRequest.process(TxnRequest.java:145)
at org.apache.cassandra.service.accord.AccordVerbHandler.doVerb(AccordVerbHandler.java:46)
- at org.apache.cassandra.net.InboundSink.lambda$new$0(InboundSink.java:78)
+ at org.apache.cassandra.net.InboundSink.lambda$new$0(InboundSink.java:78)
*/
@Ignore
@Test
@@ -173,8 +173,8 @@ public class AccordIntegrationTest extends AccordTestBase
for (int i = 0; i < keyStrings.size(); i++)
txn.withRead("row" + i, "SELECT * FROM " + keyspace + ".tbl WHERE k=" + keyStrings.get(i) + " and c=0");
- Keys keySet = txn.build().keys();
- Topologies topology = AccordService.instance().node.topology().withUnsyncedEpochs(keySet, 1);
+ Unseekables<?, ?> routables = txn.build().keys().toUnseekables();
+ Topologies topology = AccordService.instance().node.topology().withUnsyncedEpochs(routables, 1);
// we don't detect out-of-bounds read/write yet, so use this to validate we reach different shards
Assertions.assertThat(topology.totalShards()).isEqualTo(2);
});
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org