私はJobsがFlinkまたはflink.batによってJobManagerに送信できることを知っています。 FlinkがJava APIを提供してJobManagerにジョブを送信するかどうかを知りたいですか?FlinkはJob APIにジョブを投入するJava APIを提供していますか?
1
A
答えて
2
はい。接続するクラスタのタイプに応じて、ClusterClient(https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/client/program/ClusterClient.html)の実装がいくつかあります。
ジョブは、ブロッキング(同期)またはデタッチ(非同期)のいずれの方法でも実行できます。ジョブをデプロイする1つの方法は、Main ClassといくつかのサポートするJARファイル(ジョブに特別に必要な追加ライブラリ)を含むJARファイルで構成されるPackagedProgramを提供することです。
1
あなたはこのテストクラスClientTest.javaを見ることができます、より多くの構成パラメータはconfigurationを参照してください、あなたを助けることができるかもしれません。
+0
ありがとうございました。 – Hao
関連する問題
- 1. PHPはSpinxクライアントAPIを提供するようにLucene Client APIを提供していますか?
- 2. LinkedInはオフラインアクセス用のAPIを提供していますか?
- 3. React NativeはダイアログのAPIを提供していますか?
- 4. OpenWrtはパケットフィルタAPIを提供していますか?
- 5. 在庫管理システムはAPIを提供していますか?
- 6. GoogleコードはAPIを提供していますか?
- 7. TITANグラフデータベースはHTTP APIを提供していますか?
- 8. IRCTCとインド鉄道はAPIを提供していますか?
- 9. GarminはAPIのユーザーのステップカウントを提供していますか?
- 10. Rabbit MQはSOAP APIを提供していますか?
- 11. Flink REST APIを使用してAWS EMR上でFlinkジョブを実行する
- 12. Appdynamicsはプロジェクト/ジョブとユーザーを作成するためのAPIを提供していますか
- 13. APIを提供する企業は、APIの前にシムまたはプロキシを使用していますか?
- 14. 気象APIがUVインデックスを提供していますか?
- 15. JavaでRESTful JSON APIを提供
- 16. Elasticsearch Java APIに日付コンバータを提供する方法はありますか?
- 17. Hectorは複合キーをサポートするAPIを提供していますか?
- 18. Sendgrid API提供
- 19. 同じFlinkジョブでDataSet APIとDataStream APIを使用できますか?
- 20. Swiftは動的プロキシを作成するためのAPIを提供していますかJavaはReflection Proxy APIを使用していますか?
- 21. Flinkジョブを提出するときNoSuchMethodError
- 22. FlinkのLeftOuterJoin(JAVA API)
- 23. サーバーのAPIを提供している間に静的ファイルを提供できますか?
- 24. データベースにリアクティブAPIを提供する
- 25. Informatica PowercenterはセッションログにアクセスするためのAPIを提供しています
- 26. ワードプレスが検索APIを提供しています
- 27. Spring MVCはWebリンクを構築するためのJava APIを提供していますか?
- 28. Mailgun APIはsmtp応答を提供しますか?
- 29. APIはトラックBPMテンポを提供しますか?
- 30. pthread APIはマルチプロセッサ環境で同期を提供しますか?
しかし、ClusterClientにJobManagerアドレスを指定する方法はありません。アドレスの指定方法を教えてください。 – Hao