diff --git hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ha/HAAdmin.java hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ha/HAAdmin.java index a6c4a42..b934cd2 100644 --- hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ha/HAAdmin.java +++ hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ha/HAAdmin.java @@ -279,7 +279,13 @@ private int failover(CommandLine cmd) "supported with auto-failover enabled."); return -1; } - return gracefulFailoverThroughZKFCs(toNode); + try { + return gracefulFailoverThroughZKFCs(toNode); + } catch (UnsupportedOperationException e){ + errOut.println("Failover command is not supported with " + + "auto-failover enabled: " + e.getLocalizedMessage()); + return -1; + } } FailoverController fc = new FailoverController(getConf(),