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:22:09 UTC
svn commit: r1501924 - in
/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver:
Replication.java ReplicationSource.java
Author: jdcryans
Date: Wed Jul 10 19:22:08 2013
New Revision: 1501924
URL: http://svn.apache.org/r1501924
Log:
HBASE-8919 TestReplicationQueueFailover (and Compressed) can fail because the recovered queue
gets stuck on ClosedByInterruptException (first try, getting more debug)
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java?rev=1501924&r1=1501923&r2=1501924&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java Wed Jul 10 19:22:08 2013
@@ -158,6 +158,7 @@ public class Replication implements WALA
this.replicationSink.stopReplicationSinkServices();
}
}
+ scheduleThreadPool.shutdown();
}
/**
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java?rev=1501924&r1=1501923&r2=1501924&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java Wed Jul 10 19:22:08 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);
}
}
};