Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-4680 FSUtils.isInSafeMode() checks should operate on HBase root dir, where we have permissions 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1190428 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Helmling 2011-10-28 16:25:34 +00:00
parent 86f20b257f
commit b5929431a5
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGES.txt
View File

@ -417,6 +417,8 @@ Release 0.92.0 - Unreleased
HBASE-4679 Thrift null mutation error
HBASE-4304 requestsPerSecond counter stuck at 0 (Li Pi)
HBASE-4692 HBASE-4300 broke the build
HBASE-4680 FSUtils.isInSafeMode() checks should operate on HBase root dir,
where we have permissions
TESTS
HBASE-4450 test for number of blocks read: to serve as baseline for expected

14
src/main/java/org/apache/hadoop/hbase/util/FSUtils.java
View File

@ -156,16 +156,16 @@ public abstract class FSUtils {
* @return true if dfs is in safemode, false otherwise.
*
*/
private static boolean isInSafeMode(FileSystem fs) throws IOException {
private static boolean isInSafeMode(FileSystem fs, Path rootDir)
throws IOException {
// Refactored safe-mode check for HBASE-4510
if (fs instanceof DistributedFileSystem) {
Path rootPath = new Path("/");
FsPermission rootPerm = fs.getFileStatus(rootPath).getPermission();
FsPermission rootPerm = fs.getFileStatus(rootDir).getPermission();
try {
// Should be harmless to set back the path we retrieved.
// The first check server-side is the safemode, so if
// other exceptions are spewed out, we're not interested.
fs.setPermission(rootPath, rootPerm);
fs.setPermission(rootDir, rootPerm);
} catch (SafeModeException e) {
return true;
}
@ -180,8 +180,9 @@ public abstract class FSUtils {
*/
public static void checkDfsSafeMode(final Configuration conf)
throws IOException {
Path rootDir = getRootDir(conf);
FileSystem fs = FileSystem.get(conf);
if (isInSafeMode(fs)) {
if (isInSafeMode(fs, rootDir)) {
throw new IOException("File system is in safemode, it can't be written now");
}
}
@ -451,9 +452,10 @@ public abstract class FSUtils {
public static void waitOnSafeMode(final Configuration conf,
final long wait)
throws IOException {
Path rootDir = getRootDir(conf);
FileSystem fs = FileSystem.get(conf);
// Make sure dfs is not in safe mode
while (isInSafeMode(fs)) {
while (isInSafeMode(fs, rootDir)) {
LOG.info("Waiting for dfs to exit safe mode...");
try {
Thread.sleep(wait);