|
@@ -121,6 +121,7 @@ import org.apache.hadoop.service.AbstractService;
|
|
|
import org.apache.hadoop.service.CompositeService;
|
|
|
import org.apache.hadoop.service.Service;
|
|
|
import org.apache.hadoop.service.ServiceOperations;
|
|
|
+import org.apache.hadoop.util.ExitUtil;
|
|
|
import org.apache.hadoop.util.ReflectionUtils;
|
|
|
import org.apache.hadoop.util.ShutdownHookManager;
|
|
|
import org.apache.hadoop.util.StringInterner;
|
|
@@ -1405,9 +1406,7 @@ public class MRAppMaster extends CompositeService {
|
|
|
initAndStartAppMaster(appMaster, conf, jobUserName);
|
|
|
} catch (Throwable t) {
|
|
|
LOG.fatal("Error starting MRAppMaster", t);
|
|
|
- System.exit(1);
|
|
|
- } finally {
|
|
|
- LogManager.shutdown();
|
|
|
+ ExitUtil.terminate(1, t);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -1483,4 +1482,11 @@ public class MRAppMaster extends CompositeService {
|
|
|
}
|
|
|
});
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ protected void serviceStop() throws Exception {
|
|
|
+ super.serviceStop();
|
|
|
+ LogManager.shutdown();
|
|
|
+ }
|
|
|
+
|
|
|
}
|