Description
In DAGImpl there is reference to stagingDir which has likely come in from MR. There should be no reason to have a dependency on some staging dir in the DAG AM.
String user = UserGroupInformation.getCurrentUser().getShortUserName(); Path path = DAGApps.getStagingAreaDir(job.conf, user); if(LOG.isDebugEnabled()) { LOG.debug("startJobs: parent=" + path + " child=" + dagIdString); }