This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/master by this push:
new 3b4c023e0b4 HBASE-29532 Fix the potential NPE issue when the specific
recover edit path set (#7231)
3b4c023e0b4 is described below
commit 3b4c023e0b4dabdf1c83c7a1e9e60c346062d180
Author: alexdongli0829 <[email protected]>
AuthorDate: Fri Aug 29 11:43:09 2025 +1000
HBASE-29532 Fix the potential NPE issue when the specific recover edit path
set (#7231)
Co-authored-by: Dong Li <[email protected]>
Signed-off-by: Duo Zhang <[email protected]>
---
.../src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
index 1801b4d971e..7936197ff8d 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
@@ -5829,7 +5829,7 @@ public class HRegion implements HeapSize,
PropagatingConfigurationObserver, Regi
}
} catch (EOFException eof) {
if (!conf.getBoolean(RECOVERED_EDITS_IGNORE_EOF, false)) {
- Path p = WALSplitUtil.moveAsideBadEditsFile(walFS, edits);
+ Path p = WALSplitUtil.moveAsideBadEditsFile(fs, edits);
msg = "EnLongAddered EOF. Most likely due to Master failure during "
+ "wal splitting, so we have this data in another edit.
Continuing, but renaming "
+ edits + " as " + p + " for region " + this;
@@ -5843,7 +5843,7 @@ public class HRegion implements HeapSize,
PropagatingConfigurationObserver, Regi
// If the IOE resulted from bad file format,
// then this problem is idempotent and retrying won't help
if (ioe.getCause() instanceof ParseException) {
- Path p = WALSplitUtil.moveAsideBadEditsFile(walFS, edits);
+ Path p = WALSplitUtil.moveAsideBadEditsFile(fs, edits);
msg =
"File corruption enLongAddered! " + "Continuing, but renaming " +
edits + " as " + p;
LOG.warn(msg, ioe);