Index: hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationBase.java =================================================================== --- hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationBase.java (revision 1514076) +++ hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationBase.java (working copy) @@ -20,6 +20,7 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; +import org.apache.commons.logging.impl.Log4JLogger; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HBaseTestingUtility; @@ -30,9 +31,11 @@ import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.HTable; import org.apache.hadoop.hbase.client.replication.ReplicationAdmin; +import org.apache.hadoop.hbase.replication.regionserver.ReplicationSource; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.zookeeper.MiniZooKeeperCluster; import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher; +import org.apache.log4j.Level; import org.junit.AfterClass; import org.junit.BeforeClass; @@ -44,6 +47,10 @@ */ public class TestReplicationBase { + { + ((Log4JLogger) ReplicationSource.LOG).getLogger().setLevel(Level.ALL); + } + private static final Log LOG = LogFactory.getLog(TestReplicationBase.class); protected static Configuration conf1 = HBaseConfiguration.create(); Index: hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationKillRS.java =================================================================== --- hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationKillRS.java (revision 1514076) +++ hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationKillRS.java (working copy) @@ -38,10 +38,6 @@ @Category(LargeTests.class) public class TestReplicationKillRS extends TestReplicationBase { - { - ((Log4JLogger) ReplicationSource.LOG).getLogger().setLevel(Level.ALL); - } - private static final Log LOG = LogFactory.getLog(TestReplicationKillRS.class); /** 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 1514076) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -300,7 +300,8 @@ } catch (IOException ioe) { LOG.warn(this.peerClusterZnode + " Got: ", ioe); gotIOE = true; - if (ioe.getCause() instanceof EOFException) { + if (ioe.getCause() instanceof EOFException + || ioe.getMessage().equals("Cannot seek after EOF")) { boolean considerDumping = false; if (this.replicationQueueInfo.isQueueRecovered()) {