cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yu...@apache.org
Subject [2/3] git commit: Add missing part for CASSANDRA-3668
Date Wed, 07 May 2014 00:53:11 GMT
Add missing part for CASSANDRA-3668


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/90306931
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/90306931
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/90306931

Branch: refs/heads/trunk
Commit: 9030693180b1e6484ae7d1d44ef6964ca9491f49
Parents: 4f57aa0
Author: Yuki Morishita <yukim@apache.org>
Authored: Tue May 6 19:49:46 2014 -0500
Committer: Yuki Morishita <yukim@apache.org>
Committed: Tue May 6 19:49:46 2014 -0500

----------------------------------------------------------------------
 src/java/org/apache/cassandra/streaming/StreamResultFuture.java | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/90306931/src/java/org/apache/cassandra/streaming/StreamResultFuture.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/StreamResultFuture.java b/src/java/org/apache/cassandra/streaming/StreamResultFuture.java
index c04c3f1..cc7abbb 100644
--- a/src/java/org/apache/cassandra/streaming/StreamResultFuture.java
+++ b/src/java/org/apache/cassandra/streaming/StreamResultFuture.java
@@ -179,6 +179,8 @@ public final class StreamResultFuture extends AbstractFuture<StreamState>
     {
         logger.info("[Stream #{}] Session with {} is complete", session.planId(), session.peer);
         fireStreamEvent(new StreamEvent.SessionCompleteEvent(session));
+        SessionInfo sessionInfo = session.getSessionInfo();
+        coordinator.addSessionInfo(sessionInfo);
         maybeComplete();
     }
 


Mime
View raw message