scala - How to Pass argument to Oozie -
my use case following, building oozie pipeline , need pass argument.
indeed spark job must receive string date argument , great pass argument oozie workflow in order use in spark submit. got idea ? didn't find answer on google
thanks
create workflow.xml references variable
inputdate
create file job.properties defines default value
inputdate
- run job using cli, overriding default value when needed:
oozie job -run -config job.properties -dinputdate=2017-08-19
Comments
Post a Comment