You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2016/09/08 21:17:08 UTC
[3/6] hbase git commit: HBASE-16589 Adjust log level for FATAL
messages from HBaseReplicationEndpoint that are not fatal
HBASE-16589 Adjust log level for FATAL messages from HBaseReplicationEndpoint that are not fatal
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/4611b15f
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4611b15f
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4611b15f
Branch: refs/heads/branch-1.2
Commit: 4611b15f177bf1ff5cfe0535e34e481a2da36b06
Parents: a13f31a
Author: Andrew Purtell <ap...@apache.org>
Authored: Thu Sep 8 13:03:12 2016 -0700
Committer: Andrew Purtell <ap...@apache.org>
Committed: Thu Sep 8 13:03:57 2016 -0700
----------------------------------------------------------------------
.../hadoop/hbase/replication/HBaseReplicationEndpoint.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/4611b15f/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/HBaseReplicationEndpoint.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/HBaseReplicationEndpoint.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/HBaseReplicationEndpoint.java
index 7f2d2f9..6485e4a 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/HBaseReplicationEndpoint.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/HBaseReplicationEndpoint.java
@@ -130,7 +130,7 @@ public abstract class HBaseReplicationEndpoint extends BaseReplicationEndpoint
@Override
public void abort(String why, Throwable e) {
- LOG.fatal("The HBaseReplicationEndpoint corresponding to peer " + ctx.getPeerId()
+ LOG.error("The HBaseReplicationEndpoint corresponding to peer " + ctx.getPeerId()
+ " was aborted for the following reason(s):" + why, e);
}
@@ -218,7 +218,7 @@ public abstract class HBaseReplicationEndpoint extends BaseReplicationEndpoint
LOG.info("Detected change to peer region servers, fetching updated list");
replicationEndpoint.setRegionServers(fetchSlavesAddresses(replicationEndpoint.getZkw()));
} catch (KeeperException e) {
- LOG.fatal("Error reading slave addresses", e);
+ LOG.error("Error reading slave addresses", e);
}
}
}