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 982f3e3032 ninja - fix MutationJournalReplayTest.testReplayFlushed
982f3e3032 is described below
commit 982f3e303254f0d2b8c1d94713f0c5d46cbe0506
Author: Blake Eggleston <[email protected]>
AuthorDate: Mon Jun 29 09:48:12 2026 -0700
ninja - fix MutationJournalReplayTest.testReplayFlushed
---
.../org/apache/cassandra/replication/MutationJournalReplayTest.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/test/unit/org/apache/cassandra/replication/MutationJournalReplayTest.java
b/test/unit/org/apache/cassandra/replication/MutationJournalReplayTest.java
index bdafef57a4..5bb955527a 100644
--- a/test/unit/org/apache/cassandra/replication/MutationJournalReplayTest.java
+++ b/test/unit/org/apache/cassandra/replication/MutationJournalReplayTest.java
@@ -183,6 +183,10 @@ public class MutationJournalReplayTest
}
}
+ // Persisting needsReplay=false is deferred
until LogStatePersister drains the
+ // queue. There's no persister in this test,
so drain manually before replay.
+
journal.drainCleanup(journal.snapshotPendingClearReplay());
+
List<Mutation> replayed = new ArrayList<>();
journal.replay(new
DeserializedRecordConsumer<ShortMutationId,
Mutation>(MutationJournal.MutationSerializer.INSTANCE)
{
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
