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 1438507) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -552,6 +552,9 @@ } } } catch (IOException ioe) { + if (ioe instanceof EOFException && repLogReader.getPosition() == 0) { + return true; + } LOG.warn(peerClusterZnode + " Got: ", ioe); this.reader = null; // TODO Need a better way to determinate if a file is really gone but