Index: hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java (revision 1501610) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java (working copy) @@ -158,6 +158,7 @@ this.replicationSink.stopReplicationSinkServices(); } } + scheduleThreadPool.shutdown(); } /** Index: hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (revision 1501610) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -796,7 +796,7 @@ if (ex instanceof RemoteException) { ex = ((RemoteException) ex).unwrapRemoteException(); } - LOG.info("Slave cluster looks down: " + ex.getMessage()); + LOG.info("Slave cluster looks down: " + ex.getMessage(), ex); } } };