This is an automated email from the ASF dual-hosted git repository.

zhangduo pushed a commit to branch branch-2
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/branch-2 by this push:
     new 5db6e5e7626 HBASE--28666 Dropping unclosed WALTailingReaders leads to 
leaked sockets (#5994)
5db6e5e7626 is described below

commit 5db6e5e762608d891c7f3fb3f380420b5671d099
Author: Charles Connell <cconn...@hubspot.com>
AuthorDate: Sat Jun 15 22:15:20 2024 -0400

    HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sockets 
(#5994)
    
    In WALEntryStream, always use current WALTailingReader if one exists
    
    Signed-off-by: Duo Zhang <zhang...@apache.org>
    (cherry picked from commit bd8ad45a259a1b0066068e41a25ef4c9098d374a)
---
 .../org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java | 1 +
 1 file changed, 1 insertion(+)

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 6068f23ace8..1b8562bab33 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
@@ -220,6 +220,7 @@ 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 (FileNotFoundException e) {
           // For now, this could happen only when reading meta wal for meta 
replicas.
           // In this case, raising UncheckedIOException will let the endpoint 
deal with resetting

Reply via email to