This is an automated email from the ASF dual-hosted git repository.
iamaleksey 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 e1ae7d654a Fix now-incorrect Verb reference in MutationTrackingService
e1ae7d654a is described below
commit e1ae7d654a0f6c011501aebfa442ebb4b0972d61
Author: Aleksey Yeshchenko <[email protected]>
AuthorDate: Wed May 20 12:11:48 2026 +0100
Fix now-incorrect Verb reference in MutationTrackingService
---
src/java/org/apache/cassandra/replication/MutationTrackingService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/src/java/org/apache/cassandra/replication/MutationTrackingService.java
b/src/java/org/apache/cassandra/replication/MutationTrackingService.java
index bee2dd2229..1d062e5601 100644
--- a/src/java/org/apache/cassandra/replication/MutationTrackingService.java
+++ b/src/java/org/apache/cassandra/replication/MutationTrackingService.java
@@ -1498,7 +1498,7 @@ public class MutationTrackingService implements
MutationTrackingServiceMBean
// TODO (expected): backoff, rate limits, per host and
total
PullMutationsRequest request = new
PullMutationsRequest(offsets);
logger.trace("Requesting pull mutation request from
replica {} for missing offset {}", pullFrom, offsets);
-
MessagingService.instance().send(Message.out(Verb.PULL_MUTATIONS_REQ, request),
pullFrom);
+
MessagingService.instance().send(Message.out(Verb.MT_PULL_MUTATIONS_REQ,
request), pullFrom);
}
}
catch (Throwable throwable)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
