diff --git a/src/main/java/org/apache/hadoop/hbase/util/hbck/OfflineMetaRepair.java b/src/main/java/org/apache/hadoop/hbase/util/hbck/OfflineMetaRepair.java index 9e3ec50795d..8dc72f3ae2b 100644 --- a/src/main/java/org/apache/hadoop/hbase/util/hbck/OfflineMetaRepair.java +++ b/src/main/java/org/apache/hadoop/hbase/util/hbck/OfflineMetaRepair.java @@ -66,7 +66,10 @@ public class OfflineMetaRepair { // create a fsck object Configuration conf = HBaseConfiguration.create(); + // Cover both bases, the old way of setting default fs and the new. + // We're supposed to run on 0.20 and 0.21 anyways. conf.set("fs.defaultFS", conf.get(HConstants.HBASE_DIR)); + conf.set("fs.default.name", conf.get(HConstants.HBASE_DIR)); HBaseFsck fsck = new HBaseFsck(conf); boolean fixHoles = false; @@ -81,6 +84,7 @@ public class OfflineMetaRepair { String path = args[i]; conf.set(HConstants.HBASE_DIR, path); conf.set("fs.defaultFS", conf.get(HConstants.HBASE_DIR)); + conf.set("fs.default.name", conf.get(HConstants.HBASE_DIR)); } else if (cmd.equals("-fixHoles")) { fixHoles = true; } else if (cmd.equals("-fix")) {