Updated Branches: refs/heads/trunk 2ba394676 -> 918936600
Remove the assert from DataTracker.unsubscribe() Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/2e95a4f7 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/2e95a4f7 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/2e95a4f7 Branch: refs/heads/trunk Commit: 2e95a4f782387c75e5b45e9a4adf85482f4f69dd Parents: 09563ab Author: Aleksey Yeschenko <alek...@apache.org> Authored: Tue Jan 28 17:22:54 2014 -0600 Committer: Aleksey Yeschenko <alek...@apache.org> Committed: Tue Jan 28 17:22:54 2014 -0600 ---------------------------------------------------------------------- src/java/org/apache/cassandra/db/DataTracker.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/2e95a4f7/src/java/org/apache/cassandra/db/DataTracker.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/DataTracker.java b/src/java/org/apache/cassandra/db/DataTracker.java index 4fe0a5e..b128abb 100644 --- a/src/java/org/apache/cassandra/db/DataTracker.java +++ b/src/java/org/apache/cassandra/db/DataTracker.java @@ -446,8 +446,7 @@ public class DataTracker public void unsubscribe(INotificationConsumer consumer) { - boolean found = subscribers.remove(consumer); - assert found : consumer + " not subscribed"; + subscribers.remove(consumer); } public static SSTableIntervalTree buildIntervalTree(Iterable<SSTableReader> sstables)
