diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java index 5c338b8..014b9ff 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java @@ -501,15 +501,6 @@ public static Resource getContainerResource(Configuration conf) { } /* - * Helper to setup default environment for a task in YARN. - */ - private Map getContainerEnvironment(Configuration conf, boolean isMap) { - Map environment = new HashMap(); - MRHelpers.updateEnvBasedOnMRTaskEnv(conf, environment, isMap); - return environment; - } - - /* * Helper to determine what java options to use for the containers * Falls back to Map-reduces map java opts if no tez specific options * are set @@ -717,7 +708,6 @@ private Vertex createVertex(JobConf conf, MapWork mapWork, map = Vertex.create(mapWork.getName(), ProcessorDescriptor.create(procClassName) .setUserPayload(serializedConf), numTasks, getContainerResource(conf)); - map.setTaskEnvironment(getContainerEnvironment(conf, true)); map.setExecutionContext(executionContext); map.setTaskLaunchCmdOpts(getContainerJavaOpts(conf)); @@ -793,7 +783,6 @@ private Vertex createVertex(JobConf conf, ReduceWork reduceWork, reduceWork.getMaxReduceTasks() : reduceWork.getNumReduceTasks(), getContainerResource(conf)); - reducer.setTaskEnvironment(getContainerEnvironment(conf, false)); reducer.setExecutionContext(vertexExecutionContext); reducer.setTaskLaunchCmdOpts(getContainerJavaOpts(conf)); @@ -857,7 +846,6 @@ public PreWarmVertex createPreWarmVertex(TezConfiguration conf, prewarmVertex.addTaskLocalFiles(localResources); prewarmVertex.setTaskLaunchCmdOpts(getContainerJavaOpts(conf)); - prewarmVertex.setTaskEnvironment(getContainerEnvironment(conf, false)); return prewarmVertex; }