diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java index 79c4abeffe9..2ec760ccc93 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java @@ -153,7 +153,7 @@ public class ReplicationPeer implements Abortable, Closeable { @Override public void abort(String why, Throwable e) { - LOG.warn("The ReplicationPeer coresponding to peer " + clusterKey + LOG.fatal("The ReplicationPeer coresponding to peer " + clusterKey + " was aborted for the following reason(s):" + why, e); }