Function

Oozie submits a job from the run method of org.apache.oozie.client.OozieClient and obtains job information from getJobInfo.

Sample Code

Change OOZIE_URL_DEFALUT in the code example to the actual host name of any Oozie node, for example, https://10-1-131-131:21003/oozie/.

public void test() throws Exception
    {
        try
        {
        System.out.println("cluset status is " + isSecury);
        if (isSecury)
        {        
        UserGroupInformation.getLoginUser().doAs(new PrivilegedExceptionAction<Void>()
            {
               public Void run() throws Exception
               {                   
                   runMapReduceJob();
                   return null;
               }
           });
        }
        else
        {        
        runMapReduceJob();
        } 
        
        }
        catch (Exception e)
        {
           e.printStackTrace();
        }
        
    }
    
    private void runMapReduceJob() throws OozieClientException, InterruptedException
    {
        String mrJobFilePath = userConfDir + JOB_PROPERTIES_FILE;
  
        Properties conf = getJobProperties(mrJobFilePath);
        
        
        // submit and start the workflow job
        String jobId = wc.run(conf);
        
        System.out.println("Workflow job submitted: " + jobId);
        
        // wait until the workflow job finishes printing the status every 10 seconds
        while (wc.getJobInfo(jobId).getStatus() == WorkflowJob.Status.RUNNING)
        {
        System.out.println("Workflow job running ..." + jobId);
            Thread.sleep(10 * 1000);
        }
        
        // print the final status of the workflow job
        System.out.println("Workflow job completed ..."+jobId);
        System.out.println(wc.getJobInfo(jobId));
    }

Precautions

Implement the security authentication when you use the Java API to access the Oozie. For details, see section "Preparing for the Development Environment". Upload the dependent configuration file (For details about how to develop the Workflow.xml configuration file, see workflow.xml) and the jar package to the HDFS, and ensure that users who have passed the security authentication are granted the rights to access the relevant directory on the HDFS. (The owner of the directory is the authenticated users, or is in the same user group with the users).