Repository: cassandra Updated Branches: refs/heads/trunk c19aa154a -> 79f4bdb20
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/trunk Commit: 814bc7065e05e09c6a3a8992906fc8be1fa03074 Parents: bc9a61f Author: Paulo Motta <[email protected]> Authored: Thu Dec 3 17:28:33 2015 -0600 Committer: Tyler Hobbs <[email protected]> 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) {
