cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tylerho...@apache.org
Subject [1/2] cassandra git commit: Fix streaming completion in the non-MV case
Date Thu, 03 Dec 2015 23:29:59 GMT
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 <pauloricardomg@gmail.com>
Authored: Thu Dec 3 17:28:33 2015 -0600
Committer: Tyler Hobbs <tylerlhobbs@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)
             {


Mime
View raw message