http://git-wip-us.apache.org/repos/asf/oozie/blob/ddbd90f8/sharelib/pig/src/test/java/org/apache/oozie/action/hadoop/TestPigActionExecutor.java ---------------------------------------------------------------------- diff --git a/sharelib/pig/src/test/java/org/apache/oozie/action/hadoop/TestPigActionExecutor.java b/sharelib/pig/src/test/java/org/apache/oozie/action/hadoop/TestPigActionExecutor.java index 6ab9fce..5e5e94a 100644 --- a/sharelib/pig/src/test/java/org/apache/oozie/action/hadoop/TestPigActionExecutor.java +++ b/sharelib/pig/src/test/java/org/apache/oozie/action/hadoop/TestPigActionExecutor.java @@ -92,7 +92,7 @@ public class TestPigActionExecutor extends ActionExecutorTestCase { assertEquals(classes, ae.getLauncherClasses()); Element actionXml = XmlUtils.parseXml("<pig>" + - "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + "<script>SCRIPT</script>" + "<param>a=A</param>" + @@ -342,7 +342,7 @@ public class TestPigActionExecutor extends ActionExecutorTestCase { w.close(); String actionXml = "<pig>" + - "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + setPigConfig(writeStats).toXmlString(false) + "<script>" + script.getName() + "</script>" + @@ -376,7 +376,7 @@ public class TestPigActionExecutor extends ActionExecutorTestCase { w.close(); String actionXml = "<pig>" + - "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + setPigConfig(true).toXmlString(false) + "<script>" + script.getName() + "</script>" + @@ -421,7 +421,7 @@ public class TestPigActionExecutor extends ActionExecutorTestCase { getFileSystem().create(rootArchive).close(); String actionXml = "<pig>" + - " <job-tracker>" + getJobTrackerUri() + "</job-tracker>" + + " <job-tracker>" + getResourceManagerUri() + "</job-tracker>" + " <name-node>" + getNameNodeUri() + "</name-node>" + " <script>id.pig</script>" + " <file>" + jar.toString() +
http://git-wip-us.apache.org/repos/asf/oozie/blob/ddbd90f8/sharelib/spark/src/test/java/org/apache/oozie/action/hadoop/TestPyspark.java ---------------------------------------------------------------------- diff --git a/sharelib/spark/src/test/java/org/apache/oozie/action/hadoop/TestPyspark.java b/sharelib/spark/src/test/java/org/apache/oozie/action/hadoop/TestPyspark.java index 9d8d4aa..a0ff58b 100644 --- a/sharelib/spark/src/test/java/org/apache/oozie/action/hadoop/TestPyspark.java +++ b/sharelib/spark/src/test/java/org/apache/oozie/action/hadoop/TestPyspark.java @@ -24,15 +24,9 @@ import java.util.ArrayList; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import org.apache.hadoop.mapred.JobClient; -import org.apache.hadoop.mapred.JobConf; -import org.apache.hadoop.mapred.JobID; -import org.apache.hadoop.mapred.RunningJob; import org.apache.oozie.WorkflowActionBean; import org.apache.oozie.WorkflowJobBean; import org.apache.oozie.client.WorkflowAction; -import org.apache.oozie.service.HadoopAccessorService; -import org.apache.oozie.service.Services; import org.apache.oozie.service.WorkflowAppService; import org.apache.oozie.util.IOUtils; import org.apache.oozie.util.XConfiguration; @@ -61,7 +55,7 @@ public class TestPyspark extends ActionExecutorTestCase { "<jar>" + PI_EXAMPLE + "</jar>" + "<spark-opts>" +sparkOpts +"</spark-opts>" + "</spark>"; - return MessageFormat.format(script, getJobTrackerUri(), getNameNodeUri()); + return MessageFormat.format(script, getResourceManagerUri(), getNameNodeUri()); } public void testPyspark() throws Exception { http://git-wip-us.apache.org/repos/asf/oozie/blob/ddbd90f8/sharelib/spark/src/test/java/org/apache/oozie/action/hadoop/TestSparkActionExecutor.java ---------------------------------------------------------------------- diff --git a/sharelib/spark/src/test/java/org/apache/oozie/action/hadoop/TestSparkActionExecutor.java b/sharelib/spark/src/test/java/org/apache/oozie/action/hadoop/TestSparkActionExecutor.java index d97f1f0..51e412c 100644 --- a/sharelib/spark/src/test/java/org/apache/oozie/action/hadoop/TestSparkActionExecutor.java +++ b/sharelib/spark/src/test/java/org/apache/oozie/action/hadoop/TestSparkActionExecutor.java @@ -21,16 +21,10 @@ package org.apache.oozie.action.hadoop; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; -import org.apache.hadoop.mapred.JobClient; -import org.apache.hadoop.mapred.JobConf; -import org.apache.hadoop.mapred.JobID; -import org.apache.hadoop.mapred.RunningJob; -import org.apache.hadoop.yarn.client.api.YarnClient; import org.apache.oozie.WorkflowActionBean; import org.apache.oozie.WorkflowJobBean; import org.apache.oozie.client.WorkflowAction; import org.apache.oozie.service.ConfigurationService; -import org.apache.oozie.service.HadoopAccessorService; import org.apache.oozie.service.Services; import org.apache.oozie.service.SparkConfigurationService; import org.apache.oozie.service.WorkflowAppService; @@ -49,7 +43,6 @@ import java.io.Writer; import java.text.MessageFormat; import java.util.Arrays; -import java.util.Collections; import java.util.HashMap; import java.util.Map; import java.util.Properties; @@ -92,7 +85,7 @@ public class TestSparkActionExecutor extends ActionExecutorTestCase { SparkConfigurationService scs = Services.get().get(SparkConfigurationService.class); scs.destroy(); ConfigurationService.set("oozie.service.SparkConfigurationService.spark.configurations", - getJobTrackerUri() + "=" + sparkConfDir.getAbsolutePath()); + getResourceManagerUri() + "=" + sparkConfDir.getAbsolutePath()); scs.init(Services.get()); _testSetupMethods("local[*]", new HashMap<String, String>(), "client"); @@ -109,7 +102,7 @@ public class TestSparkActionExecutor extends ActionExecutorTestCase { assertEquals(Arrays.asList(SparkMain.class), ae.getLauncherClasses()); Element actionXml = XmlUtils.parseXml("<spark>" + - "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + "<master>" + master + "</master>" + (mode != null ? "<mode>" + mode + "</mode>" : "") + @@ -162,7 +155,7 @@ public class TestSparkActionExecutor extends ActionExecutorTestCase { "<arg>" + getAppPath() + "/" + OUTPUT + "</arg>" + "<spark-opts>--conf " +SPARK_TESTING_MEMORY+"</spark-opts>"+ "</spark>"; - return MessageFormat.format(script, getJobTrackerUri(), getNameNodeUri()); + return MessageFormat.format(script, getResourceManagerUri(), getNameNodeUri()); } http://git-wip-us.apache.org/repos/asf/oozie/blob/ddbd90f8/sharelib/sqoop/src/test/java/org/apache/oozie/action/hadoop/TestSqoopActionExecutor.java ---------------------------------------------------------------------- diff --git a/sharelib/sqoop/src/test/java/org/apache/oozie/action/hadoop/TestSqoopActionExecutor.java b/sharelib/sqoop/src/test/java/org/apache/oozie/action/hadoop/TestSqoopActionExecutor.java index 61d295c..691752d 100644 --- a/sharelib/sqoop/src/test/java/org/apache/oozie/action/hadoop/TestSqoopActionExecutor.java +++ b/sharelib/sqoop/src/test/java/org/apache/oozie/action/hadoop/TestSqoopActionExecutor.java @@ -22,21 +22,12 @@ import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.PathFilter; -import org.apache.hadoop.mapred.JobClient; -import org.apache.hadoop.mapred.JobConf; -import org.apache.hadoop.mapred.JobID; -import org.apache.hadoop.mapred.RunningJob; import org.apache.oozie.WorkflowActionBean; import org.apache.oozie.WorkflowJobBean; import org.apache.oozie.client.WorkflowAction; -import org.apache.oozie.service.HadoopAccessorService; -import org.apache.oozie.service.Services; import org.apache.oozie.service.WorkflowAppService; import org.apache.oozie.util.IOUtils; import org.apache.oozie.util.XConfiguration; -import org.apache.oozie.util.XmlUtils; -import org.jdom.Element; -import org.jdom.Namespace; import java.io.BufferedReader; import java.io.File; @@ -44,7 +35,6 @@ import java.io.FileInputStream; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; -import java.io.StringReader; import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; @@ -52,7 +42,6 @@ import java.text.MessageFormat; import java.util.ArrayList; import java.util.List; import java.util.Map; -import java.util.Properties; public class TestSqoopActionExecutor extends ActionExecutorTestCase { @@ -147,19 +136,19 @@ public class TestSqoopActionExecutor extends ActionExecutorTestCase { private String getActionXml() { String command = MessageFormat.format(SQOOP_COMMAND, getActionJdbcUri(), getSqoopOutputDir()); - return MessageFormat.format(SQOOP_ACTION_COMMAND_XML, getJobTrackerUri(), getNameNodeUri(), + return MessageFormat.format(SQOOP_ACTION_COMMAND_XML, getResourceManagerUri(), getNameNodeUri(), "dummy", "dummyValue", command); } private String getActionXmlEval() { String query = "select TT.I, TT.S from TT"; - return MessageFormat.format(SQOOP_ACTION_EVAL_XML, getJobTrackerUri(), getNameNodeUri(), + return MessageFormat.format(SQOOP_ACTION_EVAL_XML, getResourceManagerUri(), getNameNodeUri(), getActionJdbcUri(), query); } private String getActionXmlFreeFromQuery() { String query = "select TT.I, TT.S from TT where $CONDITIONS"; - return MessageFormat.format(SQOOP_ACTION_ARGS_XML, getJobTrackerUri(), getNameNodeUri(), + return MessageFormat.format(SQOOP_ACTION_ARGS_XML, getResourceManagerUri(), getNameNodeUri(), getActionJdbcUri(), query, getSqoopOutputDir()); } http://git-wip-us.apache.org/repos/asf/oozie/blob/ddbd90f8/sharelib/streaming/src/test/java/org/apache/oozie/action/hadoop/TestMapReduceActionExecutor.java ---------------------------------------------------------------------- diff --git a/sharelib/streaming/src/test/java/org/apache/oozie/action/hadoop/TestMapReduceActionExecutor.java b/sharelib/streaming/src/test/java/org/apache/oozie/action/hadoop/TestMapReduceActionExecutor.java index 660efd5..a21b7c7 100644 --- a/sharelib/streaming/src/test/java/org/apache/oozie/action/hadoop/TestMapReduceActionExecutor.java +++ b/sharelib/streaming/src/test/java/org/apache/oozie/action/hadoop/TestMapReduceActionExecutor.java @@ -85,7 +85,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { } public Element createUberJarActionXML(String uberJarPath, String additional) throws Exception{ - return XmlUtils.parseXml("<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + return XmlUtils.parseXml("<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + additional + "<configuration>" + "<property><name>oozie.mapreduce.uber.jar</name><value>" + uberJarPath + "</value></property>" + "</configuration>" + "</map-reduce>"); @@ -124,7 +124,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { Configuration conf = new XConfiguration(); conf.set("nameNode", getNameNodeUri()); - conf.set("jobTracker", getJobTrackerUri()); + conf.set("jobTracker", getResourceManagerUri()); conf.set(OozieClient.USER_NAME, getTestUser()); conf.set(OozieClient.APP_PATH, new File(getTestCaseDir(), "workflow.xml").toURI().toString()); conf.set(OozieClient.LOG_TOKEN, "t"); @@ -150,7 +150,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { Element eConf = eAction.getChild("name-node", eAction.getNamespace()); assertEquals(getNameNodeUri(), eConf.getText()); eConf = eAction.getChild("job-tracker", eAction.getNamespace()); - assertEquals(getJobTrackerUri(), eConf.getText()); + assertEquals(getResourceManagerUri(), eConf.getText()); // check other m-r settings eConf = eAction.getChild("configuration", eAction.getNamespace()); @@ -219,7 +219,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { List<Class<?>> classes = Arrays.<Class<?>>asList(StreamingMain.class); assertEquals(classes, ae.getLauncherClasses()); - Element actionXml = XmlUtils.parseXml("<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + Element actionXml = XmlUtils.parseXml("<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + "<configuration>" + "<property><name>mapred.input.dir</name><value>IN</value></property>" + "<property><name>mapred.output.dir</name><value>OUT</value></property>" + "</configuration>" @@ -281,7 +281,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { launcherJobConf = ae.createLauncherConf(getFileSystem(), context, action, actionXml, conf); assertNull(launcherJobConf.getJar()); // same for launcher conf (not set) - actionXml = XmlUtils.parseXml("<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + actionXml = XmlUtils.parseXml("<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + "</map-reduce>"); conf = ae.createBaseHadoopConf(context, actionXml); ae.setupActionConf(conf, context, actionXml, getFsTestCaseDir()); @@ -304,7 +304,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { } serv.getConf().setBoolean("oozie.action.mapreduce.uber.jar.enable", originalUberJarDisabled); - actionXml = XmlUtils.parseXml("<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + actionXml = XmlUtils.parseXml("<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + "<streaming>" + "<mapper>M</mapper>" + "<reducer>R</reducer>" + "<record-reader>RR</record-reader>" + "<record-reader-mapping>RRM1=1</record-reader-mapping>" @@ -322,7 +322,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { assertEquals("2", conf.get("oozie.streaming.record-reader-mapping.size")); assertEquals("2", conf.get("oozie.streaming.env.size")); - actionXml = XmlUtils.parseXml("<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + actionXml = XmlUtils.parseXml("<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + "<pipes>" + "<map>M</map>" + "<reduce>R</reduce>" + "<inputformat>IF</inputformat>" + "<partitioner>P</partitioner>" + "<writer>W</writer>" + "<program>PP</program>" + "</pipes>" + "<configuration>" @@ -533,7 +533,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { w.write("dummy\n"); w.close(); - String actionXml = "<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + "<name-node>" + String actionXml = "<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + getMapReduceConfig(inputDir.toString(), outputDir.toString()).toXmlString(false) + "</map-reduce>"; _testSubmit(MAP_REDUCE, actionXml); @@ -554,7 +554,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { ow.close(); String actionXml = "<map-reduce>" + - "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + "<configuration>" + "<property><name>mapred.mapper.class</name><value>" + MapperReducerForTest.class.getName() + @@ -584,7 +584,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { XConfiguration conf = getMapReduceConfig(inputDir.toString(), outputDir.toString()); conf.set(MapperReducerForTest.JOB_XML_OUTPUT_LOCATION, jobXml.toUri().toString()); conf.set("B", "b"); - String actionXml = "<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + "<name-node>" + String actionXml = "<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + conf.toXmlString(false) + "<config-class>" + OozieActionConfiguratorForTest.class.getName() + "</config-class>" + "</map-reduce>"; @@ -608,7 +608,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { w.write("dummy\n"); w.close(); - String actionXml = "<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + "<name-node>" + String actionXml = "<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + getMapReduceConfig(inputDir.toString(), outputDir.toString()).toXmlString(false) + "<config-class>org.apache.oozie.does.not.exist</config-class>" + "</map-reduce>"; @@ -638,7 +638,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { XConfiguration conf = getMapReduceConfig(inputDir.toString(), outputDir.toString()); conf.setBoolean("oozie.test.throw.exception", true); // causes OozieActionConfiguratorForTest to throw an exception - String actionXml = "<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + "<name-node>" + String actionXml = "<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + conf.toXmlString(false) + "<config-class>" + OozieActionConfiguratorForTest.class.getName() + "</config-class>" + "</map-reduce>"; @@ -665,7 +665,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { w.write("dummy\n"); w.close(); - String actionXml = "<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + "<name-node>" + String actionXml = "<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + getMapReduceCredentialsConfig(inputDir.toString(), outputDir.toString()).toXmlString(false) + "</map-reduce>"; @@ -729,7 +729,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { w.write("dummy\n"); w.close(); - String actionXml = "<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + "<name-node>" + String actionXml = "<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + getMapReduceUberJarConfig(inputDir.toString(), outputDir.toString()).toXmlString(false) + "</map-reduce>"; String jobID = _testSubmit(MAP_REDUCE, actionXml); @@ -817,7 +817,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { w.write("dummy\n"); w.close(); - String actionXml = "<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + "<name-node>" + String actionXml = "<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + " <streaming>" + " <mapper>cat</mapper>" + " <reducer>wc</reducer>" + " </streaming>" + streamingConf.toXmlString(false) + "<file>" @@ -907,7 +907,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { w.write("dummy\n"); w.close(); - String actionXml = "<map-reduce>" + "<job-tracker>" + getJobTrackerUri() + "</job-tracker>" + "<name-node>" + String actionXml = "<map-reduce>" + "<job-tracker>" + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() + "</name-node>" + " <pipes>" + " <program>" + programPath + "#wordcount-simple" + "</program>" + " </pipes>" + getPipesConfig(inputDir.toString(), outputDir.toString()).toXmlString(false) + "<file>" @@ -938,7 +938,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { // configuration. String actionXml = "<map-reduce>" + "<job-tracker>" - + getJobTrackerUri() + + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() @@ -1010,7 +1010,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { // configuration. String actionXml = "<map-reduce>" + "<job-tracker>" - + getJobTrackerUri() + + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() @@ -1077,7 +1077,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { // configuration. String actionXml = "<map-reduce>" + "<job-tracker>" - + getJobTrackerUri() + + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() @@ -1116,7 +1116,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { actionXml = "<map-reduce>" + "<job-tracker>" - + getJobTrackerUri() + + getResourceManagerUri() + "</job-tracker>" + "<name-node>" + getNameNodeUri() @@ -1161,7 +1161,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { mrConfig.set("mapred.job.name", mapredJobName); StringBuilder sb = new StringBuilder("<map-reduce>") - .append("<job-tracker>").append(getJobTrackerUri()) + .append("<job-tracker>").append(getResourceManagerUri()) .append("</job-tracker>").append("<name-node>") .append(getNameNodeUri()).append("</name-node>") .append(mrConfig.toXmlString(false)).append("</map-reduce>"); @@ -1258,7 +1258,7 @@ public class TestMapReduceActionExecutor extends ActionExecutorTestCase { getFileSystem().create(rootArchive).close(); String actionXml = "<map-reduce>" + - " <job-tracker>" + getJobTrackerUri() + "</job-tracker>" + + " <job-tracker>" + getResourceManagerUri() + "</job-tracker>" + " <name-node>" + getNameNodeUri() + "</name-node>" + " <main-class>CLASS</main-class>" + " <file>" + jar.toString() +
