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 b9218b64364..97c7c604c8a 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 @@ -4358,11 +4358,11 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi } for (Path edits : files) { - if (edits == null || !walFS.exists(edits)) { + if (edits == null || !fs.exists(edits)) { LOG.warn("Null or non-existent edits file: " + edits); continue; } - if (isZeroLengthThenDelete(walFS, edits)) { + if (isZeroLengthThenDelete(fs, edits)) { continue; } @@ -4392,7 +4392,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi HConstants.HREGION_EDITS_REPLAY_SKIP_ERRORS + " instead."); } if (skipErrors) { - Path p = WALSplitter.moveAsideBadEditsFile(walFS, edits); + Path p = WALSplitter.moveAsideBadEditsFile(fs, edits); LOG.error(HConstants.HREGION_EDITS_REPLAY_SKIP_ERRORS + "=true so continuing. Renamed " + edits + " as " + p, e); } else {