Repository: cassandra Updated Branches: refs/heads/cassandra-2.1 4f57aa056 -> 903069318 refs/heads/trunk 3876ad51b -> b768bb2d6
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/cassandra-2.1 Commit: 9030693180b1e6484ae7d1d44ef6964ca9491f49 Parents: 4f57aa0 Author: Yuki Morishita <[email protected]> Authored: Tue May 6 19:49:46 2014 -0500 Committer: Yuki Morishita <[email protected]> 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(); }
