From f7819e9455397fd3a9c415908762e62013b489ae Mon Sep 17 00:00:00 2001 From: Adrian Muraru Date: Wed, 7 Mar 2018 10:45:28 +0200 Subject: [PATCH] HBASE-20140 - HRegion FileSystem should be instantiated from hbase rootDir not default --- .../src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index e95a3929ab..115ea86c7a 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -6758,7 +6758,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi LOG.info("creating HRegion " + info.getTable().getNameAsString() + " HTD == " + hTableDescriptor + " RootDir = " + rootDir + " Table name == " + info.getTable().getNameAsString()); - FileSystem fs = FileSystem.get(conf); + FileSystem fs = rootDir.getFileSystem(conf); HRegionFileSystem.createRegionOnFileSystem(conf, fs, tableDir, info); WAL effectiveWAL = wal; if (wal == null && !ignoreWAL) { @@ -6872,7 +6872,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi fs = rsServices.getFileSystem(); } if (fs == null) { - fs = FileSystem.get(conf); + fs = rootDir.getFileSystem(); } return openHRegion(conf, fs, rootDir, info, htd, wal, rsServices, reporter); } @@ -7043,7 +7043,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi fs = rsServices.getFileSystem(); } if (fs == null) { - fs = FileSystem.get(conf); + fs = rootDir.getFileSystem(conf); } HRegion r = HRegion.newHRegion(tableDir, wal, fs, conf, info, htd, null); -- 2.16.2