Fix typo

apache · Oct 24, 2019 · df8efb2 · df8efb2
1 parent a8244d2
commit df8efb2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...va/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReaderThread.java b/...va/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReaderThread.java
@@ -134,7 +134,7 @@ public void run() {
           WALEntryBatch batch =
                   new WALEntryBatch(replicationBatchCountCapacity, replicationBatchSizeCapacity);
           boolean hasNext;
-          while ((hasNext = entryStream.hasNext()) != true) {
+          while ((hasNext = entryStream.hasNext()) == true) {
             Entry entry = entryStream.next();
             entry = filterEntry(entry);
             if (entry != null) {