2016-10-03 5 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:] [***[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を意味し、すべてが式に置き換えられました。私の場合、私は強く、仕事の追跡者のURLに何かが間違っていると信じている、または名前ノードにあるかもしれません。私はclouderaと同じ仕事をテストし、それは動作します。 –

答えて

1

あなたのWASBパスが間違っているように見えます。

私は以下のようになるはずです。あなたはが欠落している

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

、確認してください。

関連する問題