This is an automated email from the ASF dual-hosted git repository. zhangduo pushed a commit to branch branch-3 in repository https://gitbox.apache.org/repos/asf/hbase.git
commit a33b8c2ad1d8c9724deb461f47b099981a345f26 Author: Duo Zhang <[email protected]> AuthorDate: Sun Jun 16 17:13:14 2024 +0800 Revert "HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets (#5994)" This reverts commit 0b70d6c9cf0749f67151b862edc728e72f72d9b6. --- .../org/apache/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 8d74d0e0399..186d5b7c4d1 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 @@ class WALEntryStream implements Closeable { // 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);
