|
@@ -1080,6 +1080,8 @@ public class MRAppMaster extends CompositeService {
|
|
//start all the components
|
|
//start all the components
|
|
super.serviceStart();
|
|
super.serviceStart();
|
|
|
|
|
|
|
|
+ // set job classloader if configured
|
|
|
|
+ MRApps.setJobClassLoader(getConfig());
|
|
// All components have started, start the job.
|
|
// All components have started, start the job.
|
|
startJobs();
|
|
startJobs();
|
|
}
|
|
}
|
|
@@ -1396,8 +1398,6 @@ public class MRAppMaster extends CompositeService {
|
|
// SIGTERM I have a chance to write out the job history. I'll be closing
|
|
// SIGTERM I have a chance to write out the job history. I'll be closing
|
|
// the objects myself.
|
|
// the objects myself.
|
|
conf.setBoolean("fs.automatic.close", false);
|
|
conf.setBoolean("fs.automatic.close", false);
|
|
- // set job classloader if configured
|
|
|
|
- MRApps.setJobClassLoader(conf);
|
|
|
|
initAndStartAppMaster(appMaster, conf, jobUserName);
|
|
initAndStartAppMaster(appMaster, conf, jobUserName);
|
|
} catch (Throwable t) {
|
|
} catch (Throwable t) {
|
|
LOG.fatal("Error starting MRAppMaster", t);
|
|
LOG.fatal("Error starting MRAppMaster", t);
|