Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
We are using "yarn.resourcemanager.address" for checking the hadoop version in jobUtils. Here is the code snippet.
// Hadoop 0.20/1.x.
if (defaultConf.get("yarn.resourcemanager.address") == null) { // Duplicate hadoop 1.x code to workaround MAPREDUCE-2361 in Hadoop 0.20 // Refer OOZIE-1806. String filepath = file.toUri().getPath(); String classpath = conf.get("mapred.job.classpath.files"); conf.set("mapred.job.classpath.files", classpath == null ? filepath : classpath + System.getProperty("path.separator") + filepath); URI uri = fs.makeQualified(file).toUri(); DistributedCache.addCacheFile(uri, conf); } else { // Hadoop 0.23/2.x DistributedCache.addFileToClassPath(file, conf, fs); }
But this is being used in JavaActionExecutor to set jobTracker.
conf.set(HADOOP_YARN_RM, jobTracker);