How to run a Spark job using Oozie workflow

packageorg.apache.oozie.example

importorg.apache.spark.{SparkConf,SparkContext}

objectSpark1{
defmain(args:Array[String]){
if(args.length<2){
System.err.println("Usage:SparkTachyon<file><file>");
System.exit(1);
}

valconf=newSparkConf()
valsc=newSparkContext(conf)
vallines=sc.textFile(args(0))
valresult=lines.map(line=>line+line)
result.saveAsTextFile(args(1));
sc.stop();
}
}

packageorg.apache.oozie.example

importorg.apache.spark.{SparkConf,SparkContext}

objectSpark2{
defmain(args:Array[String]){
if(args.length<2){
System.err.println("Usage:SparkTachyon<file><file>");
System.exit(1);
}

valconf=newSparkConf()
valsc=newSparkContext(conf)
vallines=sc.textFile(args(0))
valresult=lines.map(line=>line+line)
result.saveAsTextFile(args(1));
sc.stop();
}
}

<!--
LicensedtotheApacheSoftwareFoundation(ASF)underone
ormorecontributorlicenseagreements.SeetheNOTICEfile
distributedwiththisworkforadditionalinformation
regardingcopyrightownership.TheASFlicensesthisfile
toyouundertheApacheLicense,Version2.0(the
"License");youmaynotusethisfileexceptincompliance
withtheLicense.YoumayobtainacopyoftheLicenseathttp://www.apache.org/licenses/LICENSE-2.0Unlessrequiredbyapplicablelaworagreedtoinwriting,software
distributedundertheLicenseisdistributedonan"ASIS"BASIS,
WITHOUTWARRANTIESORCONDITIONSOFANYKIND,eitherexpressorimplied.
SeetheLicenseforthespecificlanguagegoverningpermissionsand
limitationsundertheLicense.
-->
<workflow-appxmlns='uri:oozie:workflow:0.5'name='Spark'>
<startto='spark-node'/>
<actionname='spark-node'>
<sparkxmlns="uri:oozie:spark-action:0.1">
<job-tracker>${jobTracker}</job-tracker>
<name-node>${nameNode}</name-node>
<master>${master}</master>
<name>Spark</name>
<class>org.apache.oozie.example.Spark1</class>
<jar>${nameNode}/user/${wf:user()}/${examplesRoot}/apps/sparkTachyon/lib/oozie-examples.jar</jar>
<arg>alluxio://localhost:19998/LICENSE</arg>
<arg>alluxio://localhost:19998/LICENSE2</arg>
</spark>
<okto="spark-node2"/>
<errorto="fail"/>
</action>

<actionname='spark-node2'>
<sparkxmlns="uri:oozie:spark-action:0.1">
<job-tracker>${jobTracker}</job-tracker>
<name-node>${nameNode}</name-node>
<master>${master}</master>
<name>Spark2</name>
<class>org.apache.oozie.example.Spark2</class>
<jar>${nameNode}/user/${wf:user()}/${examplesRoot}/apps/sparkTachyon/lib/oozie-examples.jar</jar>
<arg>alluxio://localhost:19998/LICENSE2</arg>
<arg>alluxio://localhost:19998/LICENSE3</arg>
</spark>
<okto="end"/>
<errorto="fail"/>
</action>
<killname="fail">
<message>Workflowfailed,error
message[${wf:errorMessage(wf:lastErrorNode())}]
</message>
</kill>
<endname='end'/>
</workflow-app>

#
#LicensedtotheApacheSoftwareFoundation(ASF)underone
#ormorecontributorlicenseagreements.SeetheNOTICEfile
#distributedwiththisworkforadditionalinformation
#regardingcopyrightownership.TheASFlicensesthisfile
#toyouundertheApacheLicense,Version2.0(the
#"License");youmaynotusethisfileexceptincompliance
#withtheLicense.YoumayobtainacopyoftheLicenseat
#
#http://www.apache.org/licenses/LICENSE-2.0#
#Unlessrequiredbyapplicablelaworagreedtoinwriting,software
#distributedundertheLicenseisdistributedonan"ASIS"BASIS,
#WITHOUTWARRANTIESORCONDITIONSOFANYKIND,eitherexpressorimplied.
#SeetheLicenseforthespecificlanguagegoverningpermissionsand
#limitationsundertheLicense.
#
nameNode=hdfs://ers2.analytics.net:8020
jobTracker=ers2.analytics.net:8050
master=local[*]
queueName=default
examplesRoot=examples
oozie.use.system.libpath=true
oozie.wf.application.path=${nameNode}/user/${user.name}/${examplesRoot}/apps/sparkTachyon

+---sparkTachyon
|+---lib
||+---alluxio-core-client-1.1.0-SNAPSHOT-jar-with-dependencies.jar
||+---guava-11.0.2.jar
||+---oozie-examples.jar
|+---job.properties
|\---workflow.xml