diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java index 2715aed0e8c..82ae03fbe88 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java @@ -611,7 +611,7 @@ public class AssignmentManager { if (files[i].isFile() && files[i].getLen() > 0) { LOG.debug(dir + " has a non-empty file: " + files[i].getPath()); return true; - } else if (files[i].isDirectory() && checkWals(fs, dir)) { + } else if (files[i].isDirectory() && checkWals(fs, files[i].getPath())) { LOG.debug(dir + " is a directory and has a non-empty file: " + files[i].getPath()); return true; }