Fix for mapred.job.priority, using oozie.launcher suffix

manasaks · Oct 1, 2012 · 60b6df1 · 60b6df1
1 parent d9834c6
commit 60b6df1
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 12 deletions.
diff --git a/feed/src/main/resources/config/workflow/replication-workflow.xml b/feed/src/main/resources/config/workflow/replication-workflow.xml
@@ -35,7 +35,7 @@
 					<value>${wf:conf('mapred.job.queue.name')}</value>
 				</property>
 				<property>
-					<name>mapred.job.priority</name>
+					<name>oozie.launcher.mapred.job.priority</name>
 					<value>${wf:conf('mapred.job.priority')}</value>
 				</property>
 			</configuration>
@@ -58,7 +58,7 @@
 					<value>${wf:conf('mapred.job.queue.name')}</value>
 				</property>
 				<property>
-					<name>mapred.job.priority</name>
+					<name>oozie.launcher.mapred.job.priority</name>
 					<value>${wf:conf('mapred.job.priority')}</value>
 				</property>
 			</configuration>
@@ -86,7 +86,7 @@
 					<value>${wf:conf('mapred.job.queue.name')}</value>
 				</property>
 				<property>
-					<name>mapred.job.priority</name>
+					<name>oozie.launcher.mapred.job.priority</name>
 					<value>${wf:conf('mapred.job.priority')}</value>
 				</property>
 			</configuration>
@@ -132,7 +132,7 @@
 					<value>${wf:conf('mapred.job.queue.name')}</value>
 				</property>
 				<property>
-					<name>mapred.job.priority</name>
+					<name>oozie.launcher.mapred.job.priority</name>
 					<value>${wf:conf('mapred.job.priority')}</value>
 				</property>
 			</configuration>

diff --git a/feed/src/main/resources/config/workflow/retention-workflow.xml b/feed/src/main/resources/config/workflow/retention-workflow.xml
@@ -27,7 +27,7 @@
 					<value>${wf:conf('mapred.job.queue.name')}</value>
 				</property>
 				<property>
-					<name>mapred.job.priority</name>
+					<name>oozie.launcher.mapred.job.priority</name>
 					<value>${wf:conf('mapred.job.priority')}</value>
 				</property>
 			</configuration>
@@ -53,7 +53,7 @@
 					<value>${wf:conf('mapred.job.queue.name')}</value>
 				</property>
 				<property>
-					<name>mapred.job.priority</name>
+					<name>oozie.launcher.mapred.job.priority</name>
 					<value>${wf:conf('mapred.job.priority')}</value>
 				</property>
 			</configuration>

diff --git a/oozie/src/test/java/org/apache/ivory/oozie/workflow/IvoryPostProcessingTest.java b/oozie/src/test/java/org/apache/ivory/oozie/workflow/IvoryPostProcessingTest.java
@@ -71,10 +71,10 @@ public void setup() throws Exception {
 				"-" + Arg.WF_ENGINE_URL.getOptionName(),
 				"http://localhost:11000/oozie/",
 				"-" + Arg.LOG_DIR.getOptionName(), "target/log",
-				"-" + Arg.USER_SUBFLOW_ID.getOptionName(), "userflow@wf-id" };
+				"-" + Arg.USER_SUBFLOW_ID.getOptionName(), "userflow@wf-id"+"test" };
 		broker = new BrokerService();
-		broker.setDataDirectory("target/activemq");
 		broker.addConnector(BROKER_URL);
+		broker.setDataDirectory("target/activemq");
 		broker.setBrokerName("localhost");
 		broker.start();
 	}

diff --git a/process/src/main/resources/config/workflow/process-parent-workflow.xml b/process/src/main/resources/config/workflow/process-parent-workflow.xml
@@ -35,7 +35,7 @@
 					<value>${wf:conf('mapred.job.queue.name')}</value>
 				</property>
 				<property>
-					<name>mapred.job.priority</name>
+					<name>oozie.launcher.mapred.job.priority</name>
 					<value>${wf:conf('mapred.job.priority')}</value>
 				</property>
 			</configuration>
@@ -68,7 +68,7 @@
 					<value>${wf:conf('mapred.job.queue.name')}</value>
 				</property>
 				<property>
-					<name>mapred.job.priority</name>
+					<name>oozie.launcher.mapred.job.priority</name>
 					<value>${wf:conf('mapred.job.priority')}</value>
 				</property>
 			</configuration>
@@ -114,7 +114,7 @@
 					<value>${wf:conf('mapred.job.queue.name')}</value>
 				</property>
 				<property>
-					<name>mapred.job.priority</name>
+					<name>oozie.launcher.mapred.job.priority</name>
 					<value>${wf:conf('mapred.job.priority')}</value>
 				</property>
 			</configuration>

diff --git a/webapp/src/test/java/org/apache/ivory/resource/AbstractTestBase.java b/webapp/src/test/java/org/apache/ivory/resource/AbstractTestBase.java
@@ -68,7 +68,7 @@ public class AbstractTestBase {
     protected static final String PROCESS_TEMPLATE = "/process-template.xml";
 
     protected static final String BASE_URL = "http://localhost:15000/";
-    protected static final String REMOTE_USER="guest";
+    protected static final String REMOTE_USER=System.getProperty("user.name");
 
     protected EmbeddedServer server;