0

File Source ストリーム コンポーネントを使用して、ディレクトリからファイルを読み取り、File インスタンスをカスタム プロセッサに送信します。カスタム プロセッサはファイルを読み取り、TaskLauncher シンクを使用して特定のタスクを起動します。ディレクトリに 5 つのファイルをドロップすると、5 つのタスクが同時に起動します。私が達成しようとしているのは、各タスクを次々に実行することです。そのため、タスクの状態を監視して、別のタスクを起動する前に前のタスクが完了していることを確認する必要があります。これを実装するためのオプションは何ですか? 補足として、これを Yarn クラスターで実行しています。

ありがとう、

-フランク

4

1 に答える 1

0

YARN TaskLauncher による非同期タスクの起動が、すべてのタスクが同時に起動されているように見える理由である可能性があると思います。試すことができる 1 つの可能なアプローチは、次のトリガー要求の処理を開始する前に、タスクとタスクのステータスを実行するcustomタスク ランチャーsinkを用意することです。launcheswaitscompleted

于 2016-11-08T06:03:23.383 に答える