Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/267#discussion_r219508092
--- Diff: src/java/org/apache/cassandra/service/StorageProxy.java ---
@@ -780,8 +780,9 @@ public static void mutateMV(ByteBuffer dataKey,
Collection<Mutation> mutations,
ConsistencyLevel consistencyLevel = ConsistencyLevel.ONE;
//Since the base -> view replication is 1:1 we only need
to store the BL locally
- final Collection<InetAddressAndPort> batchlogEndpoints =
Collections.singleton(FBUtilities.getBroadcastAddressAndPort());
- BatchlogResponseHandler.BatchlogCleanup cleanup = new
BatchlogResponseHandler.BatchlogCleanup(mutations.size(), () ->
asyncRemoveFromBatchlog(batchlogEndpoints, batchUUID));
+ ReplicaPlan.ForTokenWrite replicaPlan =
ReplicaPlans.forLocalBatchlogWrite();
+ BatchlogResponseHandler.BatchlogCleanup cleanup = new
BatchlogResponseHandler.BatchlogCleanup(mutations.size(),
--- End diff --
Fixed
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
