oozie

0熱

1答えて

私はOOZIEワークフローを実行しており、map-reduceアクション内にマップのみの分散モデルフィッティングを行っています。多くのマッパーがあるので、私はyarn logs -applicationId application_xを使ってすべてのマッパータスクのYARNログをコンパイルするコードを書いています。ここで、application_xはすべてのマップタスクの親アプリケーションIDです

0熱

1答えて

ファイルとしてoozie.common.fileをインポートするImportError：oozieという名前のモジュールがありません

他のモジュールからファイルをインポートする際にこのエラーが表示されますか？誰でもその理由を教えてください。それは怠惰な仕事として、コマンドは失敗しています。フォルダ構造：私はインポートしようとしていた場所から oozie/common/file.py oozie/common/__init__.py oozie/__init__py 私の場所： oozie/mylocation/pjt.

0熱

1答えて

OozieとHueのUber Jarを使ってスパークジョブを実行する

現在、Apache Oozieを使用してSpark JobsをCDH 5.8で実行する方法を学習していますが、問題が見つかったようです。 IntelliJ> Build Artifact（Uber JAR/Fat JAR）を使用してスパークジョブをコンパイルし、後でそのマニフェストファイルを削除します。次に、spar-submitを実行してJARを実行します。それはうまく動作します。しかし、私は

0熱

1答えて

oozieから実行するとSqoopが失敗しますが、コマンドラインにはありません

oozieから実行するとSqoopアクションが失敗しますが、コマンドライン（エッジノード）に同じコマンドを貼り付けても完全に正常に実行されます。 workflow.xmlファイルの一部はoozieジョブIDから実行するとトリガーされ、その後、私は、次の次のエラー Error: com.teradata.connector.common.exception.ConnectorException: i

0熱

1答えて

オジーシェルスクリプトは...エラーメインクラス[org.apache.oozie.action.hadoop.ShellMain]、1番出口

私はoozieジョブを実行しようとしていた場合、それは、次の投げエラー Launcher ERROR, reason: Main class [org.apache.oozie.action.hadoop.ShellMain], exit code [1] 私のシェルを実行していません独立して実行するとスクリプトは正常に動作します。 job.properties nameNode=hdfs://n

0熱

2答えて

OOZIE決定ノードで論理演算子を使用する方法は？

私は最初に必要なことがあります、私はファイルが存在するかどうかを確認する必要があります与えられたHDFSの場所です。ファイルが存在する場合は、200バイトを超えるファイルのサイズをテストする必要があります。両方の結果に基づいて、私はユーザーに電子メール通知を送信する必要があります。 Iが存在しないか、ではない私は、私はにワークフローを作成する必要がありますコードの下 ${fs:fileSize

0熱

1答えて

Oozie Shell一重引用符が付いたアクションパラメータが

私はOozie Shellのアクションジョブを、いくつかのサブワークフロー構成を介して実行しようとしています。として、単一引用符で設定ファイル（workflow.xml）、私は（job.propertiesファイルから来る）いくつかの変数をラップし、書き込みをしながら： <property> <name>myVar</name> <value>'${myVar}'</valu

0熱

1答えて

oozie distcp job execution

私はdistcp操作を実行している怠惰なワークフローを持っています。ワークフローファイルは以下の通りです： <workflow-app xmlns="uri:oozie:workflow:0.3" name="distcp-wf"> <start to="distcp-node"/> <action name="distcp-node"> <distcp xmlns="uri:oo