diff --git a/src/java/org/apache/cassandra/repair/StreamingRepairTask.java b/src/java/org/apache/cassandra/repair/StreamingRepairTask.java index 1fd2b4f3d7..f7203a485e 100644 --- a/src/java/org/apache/cassandra/repair/StreamingRepairTask.java +++ b/src/java/org/apache/cassandra/repair/StreamingRepairTask.java @@ -46,15 +46,6 @@ public class StreamingRepairTask implements Runnable, StreamEventHandler this.request = request; } - /** - * Returns true if the task if the task can be executed locally, false if - * it has to be forwarded. - */ - public boolean isLocalTask() - { - return request.initiator.equals(request.src); - } - public void run() { if (request.src.equals(FBUtilities.getBroadcastAddress()))