Skip to content

Sample Oozie Workflow to test the Spark Job. In Workflow, we use the Shell action to call a Shell script. The Shell script will be invoking the Spark Pi example Job.

Notifications You must be signed in to change notification settings

AnalyticsApps/Spark-Oozie-example

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

11 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Spark_Oozie_example

Steps to run the project

Update the job.properties based on you Cluster host details and port


# Remove the workflow folders
hadoop fs -rmr /tmp/Spark_Oozie_example

# Move the workflow to hdfs
hadoop fs -put /opt/Spark_Oozie_example /tmp

# Invoke your Oozie workflow from command line.
cd /usr/iop/current/oozie-client/bin/

# Change the hostname & port based on your cluster. You can get these URL from the property oozie.base.url from Oozie
export OOZIE_URL=http://<AddHostName>:11000/oozie

# Run the Oozie Job
./oozie job -run -config /opt/Spark_Oozie_example/job.properties 

Author

Nisanth Simon - NisanthSimon@LinkedIn

About

Sample Oozie Workflow to test the Spark Job. In Workflow, we use the Shell action to call a Shell script. The Shell script will be invoking the Spark Pi example Job.

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages