From df8efb288c6ed1a3709bded46ef8324100478c8a Mon Sep 17 00:00:00 2001
From: Jeongdae Kim <kjd9306@gmail.com>
Date: Thu, 24 Oct 2019 20:07:38 +0900
Subject: [PATCH] Fix typo

---
 .../regionserver/ReplicationSourceWALReaderThread.java          | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReaderThread.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReaderThread.java
index 2061cae7983b..6f17667130e3 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReaderThread.java
+++ b/hbase-server/src/main/java/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) {