問題タブ [oozie-coordinator]

だから私は、次の問題に遭遇するまで、Oozie Java API をいじっていました。次のJavaコードを実行しようとしているとき:

これは次の例外で失敗します。

Google で関連する問題をいくつか見つけることができましたが、私が気付いた問題はコマンド ラインの Oozie クライアントにのみ関連していました。

私の主な質問は、単に次を追加するだけで、Java から別のユーザーとして Oozie ワークフローを実行できると考えていることです。

ワークフローを強制終了することでできる同様のことはありますか?

スクリプトに sqoop インポート コマンドを記述し、コーディネーター ワークフローとして oozie で実行できますか?

そうするのにうんざりしていて、実行するsqoopの絶対パスを指定しても、sqoopコマンドが見つからないというエラーが見つかりました

script.sh は次のとおりです。

sqoop import --connect 'jdbc:sqlserver://xx.xx.xx.xx' -username=sa -password -table materials --fields-terminated-by '^' -- --schema dbo -target-dir /user/hadoop/CFFC/oozie_materials

ファイルを HDFS に配置し、oozie にそのパスを指定しました。ワークフローは次のとおりです。

oozie は、mapreduce ログに sqoop コマンドが見つからないというエラーを返します。

それは良い習慣ですか？

ありがとう

フィルタリングされたすべての Oozie ジョブを強制終了するにはどうすればよいですか?

たとえば、次の条件ですべての oozie ジョブを強制終了したいとします。

変数 ${prefix} を oozie コーディネーターに渡しています。テストの場合はtestに合格し、本番環境の場合は空の stringを渡したいです。どうすればそれを達成できますか？

Apache Oozie は初めてです。私が理解している限りでは、ワークフロー ファイルまたはコーディネーター ファイル (両方とも xml 形式) を使用してアクションのワークフローを定義し、それを Oozie エンジンに送信できます。ただし、Oozie Java ライブラリもあり、このライブラリをどのように使用できるか知りたいですか? プログラムでxmlファイルを生成してエンジンに送信するためですか? 誰かが私に例を教えてください。

私は Apache Oozie を初めて使用します。私が理解している限り、ワークフロー/コーディネーター ジョブは xml ファイルで事前定義する必要があります。ただし、私の問題では、ワークフローを動的に定義する必要があります。つまり、入力ファイルによっては、ワークフローに追加のアクションが含まれる場合があります。プログラムでそれを行う方法はありますか？

jar ファイル (mymapreduce.jar) としてパックされた mapreduce ジョブがあります。実行時には、hadoop jar mymapreduce.jar StartClass -i input -p parameter1 -u parameter2 など、いくつかのパラメーターが必要です。Oozie ワークフロー ファイルにアクションとして記述するにはどうすればよいですか?