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 1384174) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -543,7 +543,17 @@ // TODO without scanning all logs dir if (sleepMultiplier == this.maxRetriesMultiplier) { LOG.warn("Waited too long for this file, considering dumping"); - return !processEndOfFile(); + try { + FileStatus stat = this.fs.getFileStatus(this.currentPath); + if (stat != null && stat.getLen() == 0) { + return !processEndOfFile(); + } + } catch (IOException e) { + // fall through + } + LOG.warn("Retry too many times on open hlog " + this.currentPath.getName() + + " Please check hlog status or HDFS .", ioe); + return false; } } return true;