KafkaでFlinkストリーミングに関する質問

Question

私は、カフカストリーミングを処理するためにフリンクジョブを昼食するJavaアプリケーションを持っています。

1. ジョブはカフカから着信streamingsのために永遠に実行されているので、アプリケーションはflinkEnv.execute("flink job name")でジョブの投入で、ここで保留されています。

   この場合、実行から返されたジョブIDを取得するにはどうすればよいですか？ジョブIDがコンソールに表示されています。ちょうど不思議ですが、jobidを取得する方法は、flinkEnv.executeがまだ戻ってこない場合です。

2. Javaでリモートサーバからジョブ名を指定してflinkジョブをキャンセルする方法はありますか？

Answer 1

現在のところ、Flinkを制御するプログラム的な方法はありません。しかし、FlinkはJavaで書かれているので、あなたがコンソールで行うことができるすべては、コンソールクラスによって呼び出される内部クラスorg.apache.flink.client.CliFrontendで行うこともできます。

代わりに、Flink JobManagerのREST APIを使用することもできます。

Answer 2

残りのAPIを使用すると、フリンクジョブプロセスを使用できます。

以下のリンクを確認してください：https://ci.apache.org/projects/flink/flink-docs-master/monitoring/rest_api.html。