Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-8919 TestReplicationQueueFailover (and Compressed) can fail because the recovered queue 

gets stuck on ClosedByInterruptException (first try, getting more debug)


git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1501924 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jean-Daniel Cryans 2013-07-10 19:22:08 +00:00
parent e79eefe78b
commit d390841912
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java
View File

@ -158,6 +158,7 @@ public class Replication implements WALActionsListener,
this.replicationSink.stopReplicationSinkServices(); this.replicationSink.stopReplicationSinkServices();
} }
} }
scheduleThreadPool.shutdown();
} }
/** /**

2
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
View File

@ -796,7 +796,7 @@ public class ReplicationSource extends Thread
if (ex instanceof RemoteException) { if (ex instanceof RemoteException) {
ex = ((RemoteException) ex).unwrapRemoteException(); ex = ((RemoteException) ex).unwrapRemoteException();
} }
LOG.info("Slave cluster looks down: " + ex.getMessage()); LOG.info("Slave cluster looks down: " + ex.getMessage(), ex);
} }
} }
}; };