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/cassandra-3.0 Commit: 7c3966bfe3d42daf97fb3b551060958d1c9c017a Parents: e438831 Author: Paulo Motta <pauloricard...@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); }