From 9ef621db90a77f55c187a037e6fc6eeb7bc0f69f Mon Sep 17 00:00:00 2001 From: Duo Zhang Date: Sun, 16 Jun 2024 17:12:00 +0800 Subject: [PATCH] Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)" This reverts commit bd8ad45a259a1b0066068e41a25ef4c9098d374a. --- .../hadoop/hbase/replication/regionserver/WALEntryStream.java | 1 - 1 file changed, 1 deletion(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java index 8d74d0e0399e..186d5b7c4d18 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java @@ -219,7 +219,6 @@ private HasNext prepareReader() { // we will read from the beginning so we should always clear the compression context reader.resetTo(-1, true); } - return HasNext.YES; } catch (IOException e) { LOG.warn("Failed to reset reader {} to pos {}, reset compression={}", currentPath, currentPositionOfEntry, state.resetCompression(), e);