diff --git a/hbase-hbck2/src/main/java/org/apache/hbase/HBCK2.java b/hbase-hbck2/src/main/java/org/apache/hbase/HBCK2.java index b9c7db3a3f..e26ce7f2a1 100644 --- a/hbase-hbck2/src/main/java/org/apache/hbase/HBCK2.java +++ b/hbase-hbck2/src/main/java/org/apache/hbase/HBCK2.java @@ -1220,15 +1220,12 @@ private int doCommandLine(CommandLine commandLine, Options options) throws IOExc } case FILESYSTEM: - try (ClusterConnection connection = connect()) { - checkHBCKSupport(connection, command); - try (FileSystemFsck fsfsck = new FileSystemFsck(getConf())) { - Pair> pair = - parseCommandWithFixAndInputOptions(purgeFirst(commands)); - return fsfsck.fsck(pair.getSecond(), pair.getFirst().hasOption("f")) != 0 - ? EXIT_FAILURE - : EXIT_SUCCESS; - } + try (FileSystemFsck fsfsck = new FileSystemFsck(getConf())) { + Pair> pair = + parseCommandWithFixAndInputOptions(purgeFirst(commands)); + return fsfsck.fsck(pair.getSecond(), pair.getFirst().hasOption("f")) != 0 + ? EXIT_FAILURE + : EXIT_SUCCESS; } case REPLICATION: