Skip to content

EMR Add Hadoop JAR Step

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

Adds a Hadoop JAR step to an EMR cluster.

Delegate Class

org.finra.dm.service.activiti.task.AddEmrHadoopJarStep

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.
stepName Y The name of Step.
jarLocation Y The location of JAR file.
mainClass N The main class to be used.
scriptArguments N The arguments delimited by the pipe character ( | ). Delimiter can be escaped by a backslash ( \ ).
continueOnError N true, false false N Action on step failure, "true": continue, "false": cancel.

Output Parameters

Name Description
{taskId}_emrStepId The step ID.

Sample Usage in Activiti XML

<serviceTask id="addHadoopJarStepServiceTask" name="Add Hadoop Jar Step" activiti:class="org.finra.dm.service.activiti.task.AddEmrHadoopJarStep">
   <extensionElements>
      <activiti:field name="namespace" stringValue="testNamespace"/>
      <activiti:field name="emrClusterDefinitionName" expression="${emrClusterDefinitionName}"/>
      <activiti:field name="emrClusterName" expression="${clusterName}"/>
      <activiti:field name="stepName" expression="${stepName}"/>
      <activiti:field name="jarLocation" expression="${jarLocation}"/>
      <activiti:field name="mainClass" expression="${mainClass}"/>
      <activiti:field name="scriptArguments" expression="${scriptArguments}"/>
      <activiti:field name="continueOnError" expression="${continueOnError}"/>
   </extensionElements>
</serviceTask>
Clone this wiki locally