Repository: cassandra Updated Branches: refs/heads/trunk 3fc381d5c -> 0d26879a9
fix comparison of addresses for event filtering in repair Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/0d26879a Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/0d26879a Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/0d26879a Branch: refs/heads/trunk Commit: 0d26879a955a3045441a5016c73c750faab03c46 Parents: 3fc381d Author: Dave Brosius <[email protected]> Authored: Mon Feb 5 22:03:06 2018 -0500 Committer: Dave Brosius <[email protected]> Committed: Mon Feb 5 22:03:06 2018 -0500 ---------------------------------------------------------------------- src/java/org/apache/cassandra/repair/RepairRunnable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/0d26879a/src/java/org/apache/cassandra/repair/RepairRunnable.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/repair/RepairRunnable.java b/src/java/org/apache/cassandra/repair/RepairRunnable.java index 5121874..ebe736d 100644 --- a/src/java/org/apache/cassandra/repair/RepairRunnable.java +++ b/src/java/org/apache/cassandra/repair/RepairRunnable.java @@ -745,7 +745,7 @@ public class RepairRunnable extends WrappedRunnable implements ProgressEventNoti for (UntypedResultSet.Row r : result) { - if (source.equals(r.getInetAddress("source"))) + if (source.address.equals(r.getInetAddress("source"))) continue; if ((uuid = r.getUUID("event_id")).timestamp() > (tcur - 1000) * 10000) seen[si].add(uuid); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
