2016-10-03 94 views
0

我試圖運行azurehdinsight集羣上的Oozie的工作流任務定義是這樣的:Azure的Oozie的工作流程

<workflow-app xmlns="uri:oozie:workflow:0.2" name="oozie-sqoop"> 
    <start to="sqoop1" /> 
    <action name="sqoop1"> 
    <sqoop xmlns="uri:oozie:sqoop-action:0.4"> 
     <job-tracker>jobtrackerhost:9010</job-tracker> 
     <name-node>wasb://[email protected]</name-node> 
     <configuration> 
     <property> 
      <name>mapred.job.queue.name</name> 
      <value>default</value> 
     </property> 
     </configuration> 
     <arg>import</arg> 
     <arg>--connect</arg> 
     <arg>jdbc:mysql://{ip}/svnadmin</arg> 
     <arg>--username</arg> 
     <arg>uname</arg> 
     <arg>--password</arg> 
     <arg>password</arg> 
     <arg>--table</arg> 
     <arg>rights</arg> 
     <arg>--hive-import</arg> 
    </sqoop> 
    <ok to="end" /> 
    <error to="fail" /> 
    </action> 
    <kill name="fail"> 
    <message>sqoop failed, error message[${wf:errorMessage(wf:lastErrorNode())}]</message> 
    </kill> 
    <end name="end" /> 
</workflow-app> 

日誌:

2016-10-04 06:16:06,816 INFO ActionStartXCommand:520 - SERVER[hn0-saint.3oitbdwtly0uzabcmledackovts0a.bx.internal.cloudapp.net] USER[saint] GROUP[-] TOKEN[] APP[oozie-sqoop] JOB[0000015-160928235712742-oozie-oozi-W] ACTION[[email protected]:start:] Start action [[email protected]:start:] with user-retry state : userRetryCount [0], userRetryMax [0], userRetryInterval [10] 
2016-10-04 06:16:06,827 INFO ActionStartXCommand:520 - SERVER[hn0-saint.3oitbdwtly0uzmledackovts0a.bx.internal.cloudapp.net] USER[saint] GROUP[-] TOKEN[] APP[oozie-sqoop] JOB[0000015-160928235712742-oozie-oozi-W] ACTION[[email protected]:start:] [***[email protected]:start:***]Action status=DONE 
2016-10-04 06:16:06,828 INFO ActionStartXCommand:520 - SERVER[hn0-saint.3oitbdwtly0uzmleklasackovts0a.bx.internal.cloudapp.net] USER[saint] GROUP[-] TOKEN[] APP[oozie-sqoop] JOB[0000015-160928235712742-oozie-oozi-W] ACTION[[email protected]:start:] [***0000015-16092823571274[email protected]:start:***]Action updated in DB! 
2016-10-04 06:16:07,508 INFO WorkflowNotificationXCommand:520 - SERVER[hn0-saint.3oitbdxbtly0uzmledackovts0a.bx.internal.cloudapp.net] USER[-] GROUP[-] TOKEN[-] APP[-] JOB[0000015-160928235712742-oozie-oozi-W] ACTION[] No Notification URL is defined. Therefore nothing to notify for job 0000015-160928235712742-oozie-oozi-W 

但不進口任何蜂巢。當我嘗試與sqoop命令相同時,它成功併成功導入配置單元。 它總是顯示狀態爲正在運行,它永遠不會變成任何東西

+0

你可以看看這個:http://stackoverflow.com/questions/27740936/oozie-sqoop-action-with-hive-import – YoungHobbit

+0

我很感謝你的努力和時間來回答這個問題。在那篇文章中所有的價值;我的意思是jobtracker網址,並全部由表達式取代;在我的情況下,我堅信作業跟蹤器url中有一些錯誤,或者可能在名稱節點中。我已經用cloudera測試過相同的工作,並且工作正常。 –

回答

1

看起來像你的WASB路徑是錯誤的,不知道你是否改變它的發佈目的。

我相信它應該如下。

<name-node>wasbs://[email protected]</name-node> 

你缺少小號,請檢查。