This is an automated email from the ASF dual-hosted git repository.
bdeggleston pushed a commit to branch cep-45-mutation-tracking
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/cep-45-mutation-tracking by
this push:
new b29fb05c93 ninja: fix
MutationTrackingPendingReadTest#testFailedAugmentClosesTheReconciledRead
b29fb05c93 is described below
commit b29fb05c93afded3bfc0b52237befbbb7bbc68a5
Author: Blake Eggleston <[email protected]>
AuthorDate: Tue Oct 27 17:01:10 2026 -0700
ninja: fix
MutationTrackingPendingReadTest#testFailedAugmentClosesTheReconciledRead
---
.../test/tracking/MutationTrackingPendingReadTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/test/distributed/org/apache/cassandra/distributed/test/tracking/MutationTrackingPendingReadTest.java
b/test/distributed/org/apache/cassandra/distributed/test/tracking/MutationTrackingPendingReadTest.java
index 6efaf203e3..6100a5dd13 100644
---
a/test/distributed/org/apache/cassandra/distributed/test/tracking/MutationTrackingPendingReadTest.java
+++
b/test/distributed/org/apache/cassandra/distributed/test/tracking/MutationTrackingPendingReadTest.java
@@ -576,9 +576,9 @@ public class MutationTrackingPendingReadTest
// the read stage rethrows the augment failure after failing the
read's promise
cluster.setUncaughtExceptionsFilter(t -> t.getMessage() != null &&
t.getMessage().startsWith("Missing mutation"));
- // node 2 is the read's only summary node; while it is down the
reconciliation stays pending until the
- // test acknowledges it by hand
- cluster.get(2).shutdown().get();
+ // node 2 is the read's only summary node; drop summary requests
so the reconciliation stays pending until
+ // the test acknowledges it by hand
+
cluster.filters().verbs(Verb.MT_SUMMARY_REQ.id).from(1).to(2).drop();
cluster.get(1).runOnInstance(() -> {
TableMetadata metadata =
Schema.instance.getTableMetadata(keyspaceName, tableName);
@@ -593,7 +593,7 @@ public class MutationTrackingPendingReadTest
MutationTrackingService.instance().localReads().beginRead(readId,
clusterMetadata,
command,
-
org.apache.cassandra.db.ConsistencyLevel.ONE,
+
org.apache.cassandra.db.ConsistencyLevel.ALL,
new int[]{ summaryNode.id() },
Dispatcher.RequestTime.forImmediateExecution(),
TrackedLocalReads.Completer.DEFAULT);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
