|
@@ -19,6 +19,7 @@ package org.apache.hadoop.hdfs.tools;
|
|
|
|
|
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_KEYTAB_FILE_KEY;
|
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_KEYTAB_FILE_KEY;
|
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_KERBEROS_PRINCIPAL_KEY;
|
|
import static org.apache.hadoop.hdfs.DFSConfigKeys.DFS_NAMENODE_KERBEROS_PRINCIPAL_KEY;
|
|
|
|
+import static org.apache.hadoop.util.ExitUtil.terminate;
|
|
|
|
|
|
import java.io.ByteArrayOutputStream;
|
|
import java.io.ByteArrayOutputStream;
|
|
import java.io.IOException;
|
|
import java.io.IOException;
|
|
@@ -188,14 +189,13 @@ public class DFSZKFailoverController extends ZKFailoverController {
|
|
new HdfsConfiguration(), args);
|
|
new HdfsConfiguration(), args);
|
|
DFSZKFailoverController zkfc = DFSZKFailoverController.create(
|
|
DFSZKFailoverController zkfc = DFSZKFailoverController.create(
|
|
parser.getConfiguration());
|
|
parser.getConfiguration());
|
|
- int retCode = 0;
|
|
|
|
try {
|
|
try {
|
|
- retCode = zkfc.run(parser.getRemainingArgs());
|
|
|
|
|
|
+ System.exit(zkfc.run(parser.getRemainingArgs()));
|
|
} catch (Throwable t) {
|
|
} catch (Throwable t) {
|
|
LOG.fatal("DFSZKFailOverController exiting due to earlier exception "
|
|
LOG.fatal("DFSZKFailOverController exiting due to earlier exception "
|
|
+ t);
|
|
+ t);
|
|
|
|
+ terminate(1, t);
|
|
}
|
|
}
|
|
- System.exit(retCode);
|
|
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|