|
@@ -370,6 +370,8 @@ public class NodeManager extends CompositeService
|
|
|
|
|
|
this.aclsManager = new ApplicationACLsManager(conf);
|
|
this.aclsManager = new ApplicationACLsManager(conf);
|
|
|
|
|
|
|
|
+ this.dirsHandler = new LocalDirsHandlerService(metrics);
|
|
|
|
+
|
|
boolean isDistSchedulingEnabled =
|
|
boolean isDistSchedulingEnabled =
|
|
conf.getBoolean(YarnConfiguration.DIST_SCHEDULING_ENABLED,
|
|
conf.getBoolean(YarnConfiguration.DIST_SCHEDULING_ENABLED,
|
|
YarnConfiguration.DEFAULT_DIST_SCHEDULING_ENABLED);
|
|
YarnConfiguration.DEFAULT_DIST_SCHEDULING_ENABLED);
|
|
@@ -393,7 +395,6 @@ public class NodeManager extends CompositeService
|
|
// NodeManager level dispatcher
|
|
// NodeManager level dispatcher
|
|
this.dispatcher = createNMDispatcher();
|
|
this.dispatcher = createNMDispatcher();
|
|
|
|
|
|
- dirsHandler = new LocalDirsHandlerService(metrics);
|
|
|
|
nodeHealthChecker =
|
|
nodeHealthChecker =
|
|
new NodeHealthCheckerService(
|
|
new NodeHealthCheckerService(
|
|
getNodeHealthScriptRunner(conf), dirsHandler);
|
|
getNodeHealthScriptRunner(conf), dirsHandler);
|