You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by jd...@apache.org on 2013/07/10 21:21:58 UTC
svn commit: r1501923 - in
/hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver:
Replication.java ReplicationSource.java
Author: jdcryans
Date: Wed Jul 10 19:21:58 2013
New Revision: 1501923
URL: http://svn.apache.org/r1501923
Log:
HBASE-8919 TestReplicationQueueFailover (and Compressed) can fail because the recovered queue
gets stuck on ClosedByInterruptException (first try, getting more debug)
Modified:
hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java
hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
Modified: hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java?rev=1501923&r1=1501922&r2=1501923&view=diff
==============================================================================
--- hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java (original)
+++ hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java Wed Jul 10 19:21:58 2013
@@ -158,6 +158,7 @@ public class Replication implements WALA
this.replicationSink.stopReplicationSinkServices();
}
}
+ scheduleThreadPool.shutdown();
}
/**
Modified: hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java?rev=1501923&r1=1501922&r2=1501923&view=diff
==============================================================================
--- hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (original)
+++ hbase/branches/0.95/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java Wed Jul 10 19:21:58 2013
@@ -796,7 +796,7 @@ public class ReplicationSource extends T
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);
}
}
};