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