Index: src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (revision 1463834) +++ src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -403,7 +403,7 @@ } catch (IOException e) { LOG.warn(peerClusterZnode + " Got while getting file size: ", e); } - } else if (currentNbEntries != 0) { + } else if (currentNbEntries == 0) { LOG.warn(peerClusterZnode + " Got EOF while reading, " + "looks like this file is broken? " + currentPath); considerDumping = true;