Skip to content

Commit

Permalink
HBASE--28666 Dropping unclosed WALTailingReaders leads to leaked sock…
Browse files Browse the repository at this point in the history
…ets (#5994)

In WALEntryStream, always use current WALTailingReader if one exists 

Signed-off-by: Duo Zhang <zhangduo@apache.org>
  • Loading branch information
charlesconnell authored Jun 16, 2024
1 parent 0e8cfdb commit bd8ad45
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -219,6 +219,7 @@ 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);
Expand Down

0 comments on commit bd8ad45

Please sign in to comment.