最初に実際にジョブを開始することなく、実行計画またはその他の方法でジョブを実行するために必要なタスクスロットの総数を決定する方法はありますか?
このドキュメントによると: https://ci.apache.org/projects/flink/flink-docs-stable/concepts/runtime.html
「Flink クラスターには、ジョブで使用される最高の並列処理と正確に同じ数のタスク スロットが必要です。プログラムに合計で含まれる (さまざまな並列処理を使用した) タスクの数を計算する必要はありません。」
StreamExecutionEnvironment から実行計画を取得し (セットアップ後、実際にはジョブを実行せずに)、実行計画 json のノードのリストから任意のノードの最大並列処理を取得すると、必要なタスク スロットの数を決定するのに十分でしょうか。ジョブを実行します。
これが当てはまらなくなる状況はありますか? または注意すべき点はありますか？