natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ninja - disable per partition limits for mutation tracking and witness ast tests

This commit is contained in:
Blake Eggleston 2026-03-24 15:13:30 -07:00
parent 5bff4a7bec
commit 6740834f3a
2 changed files with 25 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
test/distributed/org/apache/cassandra/distributed/test/cql3/MultiNodeTableWalkWithMutationTrackingTest.java
View File

@ -27,7 +27,9 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import accord.utils.Property;
import accord.utils.RandomSource;
import org.apache.cassandra.cql3.ast.CreateIndexDDL;
import org.apache.cassandra.cql3.ast.Select;
import org.apache.cassandra.distributed.Cluster;
import org.apache.cassandra.distributed.api.IInstanceConfig;
import org.apache.cassandra.schema.ReplicationType;
@ -41,17 +43,38 @@ import static org.apache.cassandra.cql3.KnownIssue.AF_MULTI_NODE_MULTI_COLUMN_AN
public class MultiNodeTableWalkWithMutationTrackingTest extends MultiNodeTableWalkBase
{
private static final Logger logger = LoggerFactory.getLogger(MultiNodeTableWalkWithMutationTrackingTest.class);
public MultiNodeTableWalkWithMutationTrackingTest()
{
super(ReadRepairStrategy.NONE, ReplicationType.tracked);
}
protected class MutationTrackingState extends MultiNodeState
{
public MutationTrackingState(RandomSource rs, Cluster cluster)
{
super(rs, cluster);
}
@Override
protected boolean allowPerPartitionLimit(Select select)
{
return false;
}
}
@Override
protected State createState(RandomSource rs, Cluster cluster)
{
return new MutationTrackingState(rs, cluster);
}
@Override
protected void preCheck(Cluster cluster, Property.StatefulBuilder builder)
{
// if a failing seed is detected, populate here
// Example: builder.withSeed(42L);
// builder.withExamples(10);
// CQL operations may have opertors such as +, -, and / (example 4 + 4), to "apply" them to get a constant value
// CQL_DEBUG_APPLY_OPERATOR = true;
// When mutations look to be lost as seen by more complex SELECTs, it can be useful to just SELECT the partition/row right after to write to see if it was safe at the time.

2
test/distributed/org/apache/cassandra/distributed/test/cql3/MultiNodeTableWalkWithWitnessesTest.java
View File

@ -44,7 +44,7 @@ public class MultiNodeTableWalkWithWitnessesTest extends MultiNodeTableWalkWithM
return List.of();
}
protected class MultiNodeState extends State
protected class MultiNodeState extends MutationTrackingState
{
public MultiNodeState(RandomSource rs, Cluster cluster)
{