私は、一連のタスクを実行する oozie のコーディネーターを持っています。各タスクは、最後の出力に依存します。各タスクは日付付きフォルダーを出力し、次を使用してその前のタスクの出力を探します
${coord:latest(0)}
これは、他に何も実行されていないときに、開発クラスターですべて正常に機能しました。oozie は 5 分ごとに別のジョブをキューに入れ、その 5 分の間に前のジョブが実行されていたため、新しいジョブがセットアップされると、必要なディレクトリが表示されます。
本番クラスターで問題が発生しました。ジョブは送信されますが、キューに入れられ、しばらく実行されませんが、それでも 5 分ごとに oozie が別のジョブをキューに入れ、初期化段階で「前の」フォルダーが割り当てられます。前のジョブが実行されていないため、まだ作成されていないため、「latest」関数は前のジョブと同じ入力を提供します。その後、10 個のジョブがすべて同じ入力を受け取ることになります...
私が必要としているのは、コーディネーター シーケンスの次のジョブが、前のジョブの実行が完了するまで作成されないようにする方法です。これを行う方法はありますか？
読んでくれてありがとう