@@ -354,7 +354,7 @@ public class HRegion implements HeapSize, PropagatingConfigurationObserver, Regi
354
354
private final int rowLockWaitDuration ;
355
355
static final int DEFAULT_ROWLOCK_WAIT_DURATION = 30000 ;
356
356
357
- private Path regionDir ;
357
+ private Path regionWalDir ;
358
358
private FileSystem walFS ;
359
359
360
360
// set to true if the region is restored from snapshot
@@ -2052,11 +2052,11 @@ FileSystem getWalFileSystem() throws IOException {
2052
2052
* @throws IOException if there is an error getting WALRootDir
2053
2053
*/
2054
2054
public Path getWALRegionDir () throws IOException {
2055
- if (regionDir == null ) {
2056
- regionDir = CommonFSUtils .getWALRegionDir (conf , getRegionInfo ().getTable (),
2055
+ if (regionWalDir == null ) {
2056
+ regionWalDir = CommonFSUtils .getWALRegionDir (conf , getRegionInfo ().getTable (),
2057
2057
getRegionInfo ().getEncodedName ());
2058
2058
}
2059
- return regionDir ;
2059
+ return regionWalDir ;
2060
2060
}
2061
2061
2062
2062
@ Override
@@ -6814,7 +6814,7 @@ public Map<byte[], List<Path>> bulkLoadHFiles(Collection<Pair<byte[], String>> f
6814
6814
boolean reqTmp = store .storeEngine .requireWritingToTmpDirFirst ();
6815
6815
if (bulkLoadListener != null ) {
6816
6816
finalPath = bulkLoadListener .prepareBulkLoad (familyName , path , copyFile ,
6817
- reqTmp ? null : regionDir .toString ());
6817
+ reqTmp ? null : fs . getRegionDir () .toString ());
6818
6818
}
6819
6819
Pair <Path , Path > pair = null ;
6820
6820
if (reqTmp ) {
0 commit comments