diff --git a/unit/java/azkaban/test/jobExecutor/JavaProcessJobTest.java b/unit/java/azkaban/test/jobExecutor/JavaProcessJobTest.java
index 21c1e92..e367a52 100644
--- a/unit/java/azkaban/test/jobExecutor/JavaProcessJobTest.java
+++ b/unit/java/azkaban/test/jobExecutor/JavaProcessJobTest.java
@@ -30,7 +30,7 @@ public class JavaProcessJobTest
" By JULIE BOSMAN \n" +
"Published: August 11, 2010 \n" +
" \n" +
- "Twelve years later, it may be Joe Fox�s turn to worry. Readers have gone from skipping small \n" +
+ "Twelve years later, it may be Joe Fox���s turn to worry. Readers have gone from skipping small \n" +
"bookstores to wondering if they need bookstores at all. More people are ordering books online \n" +
"or plucking them from the best-seller bin at Wal-Mart";
@@ -103,7 +103,7 @@ public class JavaProcessJobTest
@Test
public void testJavaJob() throws Exception {
/* initialize the Props */
- props.put(JavaProcessJob.JOB_CLASS, "azkaban.test.jobExecutor.WordCountLocal");
+ props.put(JavaProcessJob.JAVA_CLASS, "azkaban.test.jobExecutor.WordCountLocal");
props.put(ProcessJob.WORKING_DIR, ".");
props.put("input", inputFile);
props.put("output", outputFile);
@@ -114,7 +114,7 @@ public class JavaProcessJobTest
@Test
public void testJavaJobHashmap() throws Exception {
/* initialize the Props */
- props.put(JavaProcessJob.JOB_CLASS, "azkaban.test.executor.SleepJavaJob");
+ props.put(JavaProcessJob.JAVA_CLASS, "azkaban.test.executor.SleepJavaJob");
props.put("seconds", 1);
props.put(ProcessJob.WORKING_DIR, ".");
props.put("input", inputFile);
@@ -125,7 +125,7 @@ public class JavaProcessJobTest
@Test
public void testFailedJavaJob() throws Exception {
- props.put(JavaProcessJob.JOB_CLASS, "azkaban.test.jobExecutor.WordCountLocal");
+ props.put(JavaProcessJob.JAVA_CLASS, "azkaban.test.jobExecutor.WordCountLocal");
props.put(ProcessJob.WORKING_DIR, ".");
props.put("input", errorInputFile);
props.put("output", outputFile);
diff --git a/unit/java/azkaban/test/jobExecutor/WordCountLocal.java b/unit/java/azkaban/test/jobExecutor/WordCountLocal.java
index c22119e..d63fc39 100644
--- a/unit/java/azkaban/test/jobExecutor/WordCountLocal.java
+++ b/unit/java/azkaban/test/jobExecutor/WordCountLocal.java
@@ -3,15 +3,18 @@ package azkaban.test.jobExecutor;
import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.FileOutputStream;
+import java.io.FileReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.util.HashMap;
import java.util.Map;
+import java.util.Properties;
import java.util.StringTokenizer;
import org.apache.log4j.Logger;
import azkaban.jobExecutor.AbstractJob;
+import azkaban.jobExecutor.ProcessJob;
import azkaban.utils.Props;
public class WordCountLocal extends AbstractJob {
@@ -20,6 +23,13 @@ public class WordCountLocal extends AbstractJob {
private String _output = null;
private Map<String, Integer> _dic = new HashMap<String,Integer>();
+ public static void main(String[] args) throws Exception {
+ String propsFile = System.getenv(ProcessJob.JOB_PROP_ENV);
+ System.out.println("propsFile: " + propsFile);
+ Props prop = new Props(null, propsFile);
+ WordCountLocal instance = new WordCountLocal("", prop);
+ instance.run();
+ }
public WordCountLocal(String id, Props prop)
{
super(id, Logger.getLogger(WordCountLocal.class));
diff --git a/unit/java/azkaban/test/utils/EmailMessageTest.java b/unit/java/azkaban/test/utils/EmailMessageTest.java
index 43bf216..8ab509e 100644
--- a/unit/java/azkaban/test/utils/EmailMessageTest.java
+++ b/unit/java/azkaban/test/utils/EmailMessageTest.java
@@ -3,8 +3,10 @@ package azkaban.test.utils;
import java.io.IOException;
import javax.mail.MessagingException;
+
import org.junit.After;
import org.junit.Before;
+import org.junit.Ignore;
import org.junit.Test;
import azkaban.utils.EmailMessage;
@@ -29,6 +31,7 @@ public class EmailMessageTest {
public void tearDown() throws Exception {
}
+ @Ignore
@Test
public void testSendEmail() throws IOException {
em.addToAddress(toAddr);