答えて

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を提供することです。

+0

しかし、ClusterClientにJobManagerアドレスを指定する方法はありません。アドレスの指定方法を教えてください。 – Hao

1

あなたはこのテストクラスClientTest.javaを見ることができます、より多くの構成パラメータはconfigurationを参照してください、あなたを助けることができるかもしれません。

+0

ありがとうございました。 – Hao

関連する問題