Repository: cassandra Updated Branches: refs/heads/cassandra-3.1 2a33c3b19 -> 29c653de6
Fix streaming completion in the non-MV case Patch by Paulo Motta; reviewed by Yuki Morishita for CASSANDRA-10803 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/814bc706 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/814bc706 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/814bc706 Branch: refs/heads/cassandra-3.1 Commit: 814bc7065e05e09c6a3a8992906fc8be1fa03074 Parents: bc9a61f Author: Paulo Motta <pauloricard...@gmail.com> Authored: Thu Dec 3 17:28:33 2015 -0600 Committer: Tyler Hobbs <tylerlho...@gmail.com> Committed: Thu Dec 3 17:28:33 2015 -0600 ---------------------------------------------------------------------- src/java/org/apache/cassandra/streaming/StreamReceiveTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/814bc706/src/java/org/apache/cassandra/streaming/StreamReceiveTask.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/streaming/StreamReceiveTask.java b/src/java/org/apache/cassandra/streaming/StreamReceiveTask.java index dfc91f9..0230d14 100644 --- a/src/java/org/apache/cassandra/streaming/StreamReceiveTask.java +++ b/src/java/org/apache/cassandra/streaming/StreamReceiveTask.java @@ -209,9 +209,9 @@ public class StreamReceiveTask extends StreamTask cfs.keyspace.getName(), cfs.getTableName()); } } - task.session.taskCompleted(task); } } + task.session.taskCompleted(task); } catch (Throwable t) {