ninja - fix MutationJournalReplayTest.testReplayFlushed

bdeggleston · bdeggleston · commit 982f3e303254 · 2026-06-29T09:48:12.000-07:00
diff --git a/test/unit/org/apache/cassandra/replication/MutationJournalReplayTest.java b/test/unit/org/apache/cassandra/replication/MutationJournalReplayTest.java
@@ -183,6 +183,10 @@ class Bounds
                                       }
                                   }
 
+                                  // 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)
                                   {

Original file line number	Diff line number	Diff line change
`@@ -183,6 +183,10 @@ class Bounds`
`183`	`183`	`}`
`184`	`184`	`}`
`185`	`185`
	`186`	`+ // Persisting needsReplay=false is deferred until LogStatePersister drains the`
	`187`	`+ // queue. There's no persister in this test, so drain manually before replay.`
	`188`	`+ journal.drainCleanup(journal.snapshotPendingClearReplay());`
	`189`	`+`
`186`	`190`	`List<Mutation> replayed = new ArrayList<>();`
`187`	`191`	`journal.replay(new DeserializedRecordConsumer<ShortMutationId, Mutation>(MutationJournal.MutationSerializer.INSTANCE)`
`188`	`192`	`{`