筆記-oozieOozie是用于Hadoop平臺開源工作流調(diào)度引擎

OozieHadoop屬于web應(yīng)用程序，由Oozieclient和OozieServerOozieServer運行于JavaServlet容器（Tomcat）中的web OozieeOoziee

ClouderaMangerOozieWeb 下unzipext-2.2.zip-dOozie服務(wù)中配置啟用web保存，重啟oozie12oozie.service.callablequeueservice.callable.concurrency（節(jié)點并發(fā)3oozie.service.callablequeueservice.queue.size（隊列大小4oozie.service.ActionService.executor.ext.classes（擴展web管理地任務(wù)列表查任務(wù)狀態(tài)查流程返回信節(jié)點信息查流程圖信日志查系統(tǒng)信息查看和配OozieCLIooziejob- -pertiesooziejob- -kill0000002-150713234209387-oozie-oozi-ooziejob- -pertiesooziejob-oozie -perties–start0000003-150713234209387-Job配置

hdfs地全 coordinator.xml地bundle.xml地WorkFlow<workflow-appxmlns="uri:oozie:workflow:0.4"name=“workflow基本的EL函StringfirstNotNull(Stringvalue1,StringStringconcat(Strings1,StringStringreplaceAll(Stringsrc,Stringregex,StringStringappendAll(Stringsrc,Stringappend,StringStringtrim(StringStringurlEncode(StringStringStringtoJsonStr(Map)(sinceOozieStringtoPropertiesStr(Map)(sinceOozieStringtoConfigurationStr(Map)(sinceOozieWorkFlowStringwf:id()workflow作業(yè)Stringwf:name()workflow作業(yè)Stringwf:appPathworkflowStringwf:conf(Stringname)workflowStringwf:user(jobStringwf:callback(StringstateVar)URL，intwf:run()–返回workflow的運 Mapwf:actionData(Stringnodeintwf:actionExternalStatus(Stringnode)Stringwf:lastErrorNode()ERRORStringwf:errorCode(StringnodejobStringwf:errorMessage(Stringmessage)jobHDFSbooleanfs:exists(Stringbooleanfs:isDir(Stringlongfs:dirSize(Stringpath) 則返 longfs:fileSize(Stringpath)longfs:blockSize(Stringpath)3、節(jié)A、流程控制節(jié)startworkflowendworkflowdecisionswitchsub-workflowkillforkjoin（與fork一起使用B、動作節(jié)s

<decisionname="[NODE-<case<case<defaultto="[NODE_NAME]"<forkname="[FORK-NODE-<pathstart="[NODE-NAME]"<pathstart="[NODE-NAME]"<joinname="[JOIN-NODE-NAME]"to="[NODE-NAME]" 節(jié) --<workflow-appxmlns="uri:oozie:workflow:0.3" -<start -<action - -<job-tracker>${jobTracker}</job-<name-node>${nameNode}</name-<argument>hi in <ok<error<kill<message>Map/Reducefailed,error<end</workflow-調(diào)用調(diào)用impala--<workflow-appxmlns="uri:oozie:workflow:0.4"name="impala-<start -<action - -<job-tracker>${jobTracker}</job-<name-node>${nameNode}</name-<exec>impala- <argument>-<argument>-<argument>invalidate<capture- </workflow-fs節(jié)–<workflow-appname="[WF-DEF-NAME]"<actionname="[NODE-<delete<mkdir<movesource='[SOURCE- - odpath='[PATH]'permissions='[PERMISSIONS]'dir-files='false'<touchzpath='[PATH]'<chgrppath='[PATH]'group='[GROUP]'dir-files='false'<okto="[NODE-<errorto="[NODE-–

<workflow-appxmlns="uri:oozie:workflow:0.3"name="mr-wc-<startto="mr-<actionname="mr-<job-tracker>${jobTracker}</job-<name-node>${nameNode}</name-<deletepath="${nameNode}/user/path"<mkdirpat