Author: tucu
Date: Fri Mar 23 15:19:30 2012
New Revision: 1304433
URL: http://svn.apache.org/viewvc?rev=1304433&view=rev
Log:
OOZIE-779 Oozie cannot submit jobs to hadoop 0.23 if running in non-default
host:port (tucu)
Modified:
incubator/oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/JavaActionExecutor.java
incubator/oozie/trunk/release-log.txt
Modified:
incubator/oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/JavaActionExecutor.java
URL:
http://svn.apache.org/viewvc/incubator/oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/JavaActionExecutor.java?rev=1304433&r1=1304432&r2=1304433&view=diff
==============================================================================
---
incubator/oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/JavaActionExecutor.java
(original)
+++
incubator/oozie/trunk/core/src/main/java/org/apache/oozie/action/hadoop/JavaActionExecutor.java
Fri Mar 23 15:19:30 2012
@@ -76,6 +76,8 @@ public class JavaActionExecutor extends
private static final String HADOOP_USER = "user.name";
private static final String HADOOP_JOB_TRACKER = "mapred.job.tracker";
+ private static final String HADOOP_JOB_TRACKER_2 =
"mapreduce.jobtracker.address";
+ private static final String HADOOP_YARN_RM =
"yarn.resourcemanager.address";
private static final String HADOOP_NAME_NODE = "fs.default.name";
public static final String OOZIE_COMMON_LIBDIR = "oozie";
public static final int MAX_EXTERNAL_STATS_SIZE_DEFAULT =
Integer.MAX_VALUE;
@@ -95,6 +97,8 @@ public class JavaActionExecutor extends
DISALLOWED_PROPERTIES.add(HADOOP_USER);
DISALLOWED_PROPERTIES.add(HADOOP_JOB_TRACKER);
DISALLOWED_PROPERTIES.add(HADOOP_NAME_NODE);
+ DISALLOWED_PROPERTIES.add(HADOOP_JOB_TRACKER_2);
+ DISALLOWED_PROPERTIES.add(HADOOP_YARN_RM);
}
public JavaActionExecutor() {
@@ -185,6 +189,8 @@ public class JavaActionExecutor extends
JobConf conf =
Services.get().get(HadoopAccessorService.class).createJobConf(jobTracker);
conf.set(HADOOP_USER,
context.getProtoActionConf().get(WorkflowAppService.HADOOP_USER));
conf.set(HADOOP_JOB_TRACKER, jobTracker);
+ conf.set(HADOOP_JOB_TRACKER_2, jobTracker);
+ conf.set(HADOOP_YARN_RM, jobTracker);
conf.set(HADOOP_NAME_NODE, nameNode);
conf.set("mapreduce.fileoutputcommitter.marksuccessfuljobs", "true");
return conf;
Modified: incubator/oozie/trunk/release-log.txt
URL:
http://svn.apache.org/viewvc/incubator/oozie/trunk/release-log.txt?rev=1304433&r1=1304432&r2=1304433&view=diff
==============================================================================
--- incubator/oozie/trunk/release-log.txt (original)
+++ incubator/oozie/trunk/release-log.txt Fri Mar 23 15:19:30 2012
@@ -1,5 +1,6 @@
-- Oozie 3.2.0 release
+OOZIE-779 Oozie cannot submit jobs to hadoop 0.23 if running in non-default
host:port (tucu)
OOZIE-774 Implement a coord:conf EL function to access configuration
properties from Oozie coordinator XML files (Maxime via Mohammad)
OOZIE-777 Hadoop 0.23 removed org.apache.hadoop.mapred.Task$Counter group name
breaking EL counters() (tucu)
OOZIE-776 custom-main example job.properties is missing the activation of
sharelib (tucu)
