diff --git a/CHANGES.txt b/CHANGES.txt index 21084b8c72..a51f98d614 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,5 +1,6 @@ 4.1.5 Merged from 4.0: + * Remove redundant code in StorageProxy#sendToHintedReplicas (CASSANDRA-19412) * Remove bashisms for mx4j tool in cassandra-env.sh (CASSANDRA-19416) Merged from 3.11: Merged from 3.0: diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java b/src/java/org/apache/cassandra/service/StorageProxy.java index b96120cbb2..0b45db5f2d 100644 --- a/src/java/org/apache/cassandra/service/StorageProxy.java +++ b/src/java/org/apache/cassandra/service/StorageProxy.java @@ -1472,8 +1472,6 @@ public class StorageProxy implements StorageProxyMBean Replica localReplica = null; Collection endpointsToHint = null; - List backPressureHosts = null; - for (Replica destination : plan.contacts()) { checkHintOverload(destination); @@ -1513,11 +1511,6 @@ public class StorageProxy implements StorageProxyMBean messages.add(destination); } - - if (backPressureHosts == null) - backPressureHosts = new ArrayList<>(plan.contacts().size()); - - backPressureHosts.add(destination.endpoint()); } } else