Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
Oozie workflow - invoked from Java using Oozie Java API
import java.util.Properties;
import org.apache.oozie.client.OozieClient;
import org.apache.oozie.client.WorkflowJob;
public class myOozieWorkflowJavaAPICall {
public static void main(String[] args) {
OozieClient wc = new OozieClient("http://cdh-dev01:11000/oozie");
Properties conf = wc.createConfiguration();
conf.setProperty("nameNode", "hdfs://");
conf.setProperty("jobTracker", "cdh-jt01:8021");
conf.setProperty("queueName", "default");
conf.setProperty("oozie.libpath", "${nameNode}/user/oozie/share/lib");
conf.setProperty("oozie.use.system.libpath", "true");
conf.setProperty("", "true");
conf.setProperty(OozieClient.APP_PATH, "${appPath}");
conf.setProperty("inputDir", "${oozieProjectRoot}/data/*/*/*/*/*");
conf.setProperty("outputDir", "${appPath}/output");
try {
String jobId =;
System.out.println("Workflow job, " + jobId + " submitted");
while (wc.getJobInfo(jobId).getStatus() == WorkflowJob.Status.RUNNING) {
System.out.println("Workflow job running ...");
Thread.sleep(10 * 1000);
System.out.println("Workflow job completed ...");
} catch (Exception r) {
System.out.println("Errors " + r.getLocalizedMessage());
To run this sample:
1. You need to have installed code from my blog on the Oozie java mail action-
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment