組み込みFlinkインスタンス上のJobManagerはどこにありますか？

Question

私は複数の（マイクロ）サービスでアプリケーションを開発しています。
私はFlink（over Kafka）を使ってサービス間のメッセージをストリーミングしています。 FlinkはJavaアプリケーションに組み込まれており、それぞれが別々のドッカーコンテナで実行されています。 私がFlinkを試しているのは初めてです。ドキュメントを読んだ後も、私はまだ基​​本的なものがないと感じています。

ジョブを管理しているのは誰ですか？
JobManagerはどこで実行されていますか？
処理を監視するにはどうすればよいですか？

おかげで、

モシェ

Answer 1

は私がFLINKフォワード2016でステファン・ユエンによってthis talkをお勧めしますそれは別の展開だけでなく、将来の目標のために、現在のApache FLINKアーキテクチャ（10時45分）を説明しています。

一般に、JobManagerはFlinkジョブを管理しており、TaskManagersは複数のタスクからなるジョブを実行します。コンポーネントの編成方法は、展開（ローカル、Flinkクラスタ、YARN、Mesosなど）によって異なります。

処理を監視する最適なツールは、デフォルトでポート8081のFlink Web UIです。デバッグおよび監視のさまざまな指標（例：checkpointingまたはback-pressure）を提供します。