This is an automated email from the ASF dual-hosted git repository.
aweisberg pushed a commit to branch cep-15-accord
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/cep-15-accord by this push:
new 15a1ee9de1 Fix ShortAccordSimulationTest
15a1ee9de1 is described below
commit 15a1ee9de1945389d2688a8ff463cfce61813903
Author: Ariel Weisberg <[email protected]>
AuthorDate: Thu Jan 30 10:24:01 2025 -0500
Fix ShortAccordSimulationTest
Patch by Ariel Weisberg; Reviewed by Alex Petrov for CASSANDRA-20264
---
.../main/org/apache/cassandra/simulator/paxos/Ballots.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git
a/test/simulator/main/org/apache/cassandra/simulator/paxos/Ballots.java
b/test/simulator/main/org/apache/cassandra/simulator/paxos/Ballots.java
index c57f49341f..989626f1b6 100644
--- a/test/simulator/main/org/apache/cassandra/simulator/paxos/Ballots.java
+++ b/test/simulator/main/org/apache/cassandra/simulator/paxos/Ballots.java
@@ -27,12 +27,16 @@ import org.apache.cassandra.db.ClusteringComparator;
import org.apache.cassandra.db.ColumnFamilyStore;
import org.apache.cassandra.db.DecoratedKey;
import org.apache.cassandra.db.Keyspace;
+import org.apache.cassandra.db.ReadCommand.PotentialTxnConflicts;
import org.apache.cassandra.db.ReadExecutionController;
import org.apache.cassandra.db.SinglePartitionReadCommand;
import org.apache.cassandra.db.Slice;
import org.apache.cassandra.db.Slices;
import org.apache.cassandra.db.SystemKeyspace;
+import org.apache.cassandra.db.filter.ClusteringIndexSliceFilter;
import org.apache.cassandra.db.filter.ColumnFilter;
+import org.apache.cassandra.db.filter.DataLimits;
+import org.apache.cassandra.db.filter.RowFilter;
import org.apache.cassandra.db.marshal.Int32Type;
import org.apache.cassandra.db.marshal.TimeUUIDType;
import org.apache.cassandra.db.memtable.Memtable;
@@ -200,7 +204,8 @@ public class Ballots
public static long latestBallotFromBaseTable(DecoratedKey key,
TableMetadata metadata)
{
- SinglePartitionReadCommand cmd =
SinglePartitionReadCommand.create(metadata, 0, key, Slice.ALL);
+ ClusteringIndexSliceFilter filter = new
ClusteringIndexSliceFilter(Slices.with(metadata.comparator, Slice.ALL), false);
+ SinglePartitionReadCommand cmd =
SinglePartitionReadCommand.create(metadata, 0, ColumnFilter.all(metadata),
RowFilter.none(), DataLimits.NONE, key, filter, PotentialTxnConflicts.ALLOW);
try (ReadExecutionController controller = cmd.executionController();
UnfilteredPartitionIterator partitions = cmd.executeLocally(controller))
{
if (!partitions.hasNext())
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
