Index: src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (revision 158995) +++ src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -524,7 +524,15 @@ } } } catch (IOException ioe) { - LOG.warn(peerClusterZnode + " Got: ", ioe); + try { + FileStatus stat = this.fs.getFileStatus(this.currentPath); + if(stat.getLen() != 0){ + LOG.warn(peerClusterZnode + " Got: ", ioe); + } + } catch (IOException e) { + LOG.warn(peerClusterZnode + " Got: ", ioe); + } + // TODO Need a better way to determinate if a file is really gone but // TODO without scanning all logs dir if (sleepMultiplier == this.maxRetriesMultiplier) {