You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by yu...@apache.org on 2015/12/22 21:30:24 UTC
[04/10] cassandra git commit: Log error when stream session fails
Log error when stream session fails
patch by Paulo Motta; reviewed by yukim for CASSANDRA-9294
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/7c3966bf
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/7c3966bf
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/7c3966bf
Branch: refs/heads/trunk
Commit: 7c3966bfe3d42daf97fb3b551060958d1c9c017a
Parents: e438831
Author: Paulo Motta <pa...@gmail.com>
Authored: Thu Dec 3 13:28:18 2015 -0800
Committer: Yuki Morishita <yu...@apache.org>
Committed: Tue Dec 22 14:29:08 2015 -0600
----------------------------------------------------------------------
CHANGES.txt | 1 +
src/java/org/apache/cassandra/streaming/StreamSession.java | 3 +++
2 files changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/7c3966bf/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index 581784e..82176c5 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
2.1.13
+ * Log error when stream session fails (CASSANDRA-9294)
* Fix bugs in commit log archiving startup behavior (CASSANDRA-10593)
* (cqlsh) further optimise COPY FROM (CASSANDRA-9302)
* Allow CREATE TABLE WITH ID (CASSANDRA-9179)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/7c3966bf/src/java/org/apache/cassandra/streaming/StreamSession.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/StreamSession.java b/src/java/org/apache/cassandra/streaming/StreamSession.java
index 63219d8..98a6f1f 100644
--- a/src/java/org/apache/cassandra/streaming/StreamSession.java
+++ b/src/java/org/apache/cassandra/streaming/StreamSession.java
@@ -617,6 +617,7 @@ public class StreamSession implements IEndpointStateChangeSubscriber
*/
public synchronized void sessionFailed()
{
+ logger.error("[Stream #{}] Remote peer {} failed stream session.", planId(), peer.getHostAddress());
closeSession(State.FAILED);
}
@@ -665,11 +666,13 @@ public class StreamSession implements IEndpointStateChangeSubscriber
public void onRemove(InetAddress endpoint)
{
+ logger.error("[Stream #{}] Session failed because remote peer {} has left.", planId(), peer.getHostAddress());
closeSession(State.FAILED);
}
public void onRestart(InetAddress endpoint, EndpointState epState)
{
+ logger.error("[Stream #{}] Session failed because remote peer {} was restarted.", planId(), peer.getHostAddress());
closeSession(State.FAILED);
}