oozie 적용중

oozie

coordinator (xml 표기)

<action>

<workflow>

<app-path>${appPath}</app-path>

<configuration>

<property>

<name>nameNode</name>

<value>${nameNode}</value>

</property>

.... 기타 파라미터등등

</configuration>

</workflow>

</action>

job_properties (.properties) 

- workflow 에 각종 정보(경로 , 파라미터 , 실행 시간등등 설정)

appPath=...

nameNode=...

subworkflow (xml 표기)

actions 들의 실행 flow정의

actions들은 Map-Reduce , java application , Pig , hive , sh 등등..

<workflow-app xmlns="uri:oozie:workflow:0.0" name="configu name">

<start to="시작할action name">

<action name="액션name">

<ssh xmlns="uri:oozie:ssh-action:0.2">

<host>${host}</host>

<command>sh 경로/실행할쉘.sh</command>

<arg>파라미터</arg>

</ssh>

<ok to="성공할때 갈 action">

<error to="에러 발생시 갈 action">

</action>

<kill name="에러발생">

<message></message>

</kill>

<end name="종료action">

</workflow-app>

coordinator 배포

hadoop fs -put -f 해당파일 /경로/workflows/coordinator/

subworkflows 배포

hadoop fs -put -f 해당파일 /경로/workflows/

실행

oozie job -config 실행할porperties -run

(실행하면 job_id 생성됨)

재실행

job 정보

생성된job_id