Skip to content

Check EMR Oozie Workflow Job

Nate Weisz edited this page Oct 6, 2015 · 4 revisions

Provides details on a previously submitted Oozie workflow. The Oozie workflow job must have been submitted using EMR Oozie Workflow Post REST endpoint or Run Oozie Workflow Activiti task.

Delegate Class

org.finra.dm.service.activiti.task.CheckEmrOozieWorkflowJob

Input Parameters

Name Required Accepted Values Default Value Case Sensitive Description
namespace Y N The name of a valid namespace known by the system.
emrClusterDefinitionName Y N The name of EMR definition. Available definitions are defined EMR Cluster Definition.
emrClusterName Y N The name of EMR cluster.
oozieWorkflowJobId N Y The oozie workflow job Id.
verbose N true, false false N If true, detailed information such as action details and job logs will be returned. If false or not specified, only status, start time and end time will be returned.

Output Parameters

Name Description
{taskId}_jsonResponse JSON response of the check EMR Oozie job. Please refer to EMR Oozie Workflow Get for details.

Sample Usage in Activiti XML

With emrStepId and verbose=true

<serviceTask id="checkEmrOozieWorkflowJobTask" name="Check Oozie Job" activiti:class="org.finra.dm.service.activiti.task.CheckEmrOozieWorkflowJob">
   <extensionElements>
      <activiti:field name="namespace" stringValue="testNamespace"/>
      <activiti:field name="emrClusterDefinitionName" expression="${emrClusterDefinitionName}"/>
      <activiti:field name="emrClusterName" expression="${clusterName}"/>
      <activiti:field name="oozieWorkflowJobId" expression="${oozieWorkflowJobId}"/>
      <activiti:field name="verbose" stringValue="true"/>
   </extensionElements>
</serviceTask>
Clone this wiki locally