我知道工作可以通过flink或flink.bat提交给jobmanager。我想知道flink是否提供JavaAPI将作业提交给jobmanager？
kmb7vmvb1#
你可以看看这个测试类clienttest.java，也许能帮到你，更多配置参数请看配置。
f2uvfpb92#
对。根据要连接的集群类型，clusterclient有几种实现(https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/client/program/clusterclient.html).它可以以阻塞（同步）或分离（异步）方式运行作业。部署作业的一种方法是提供一个packagedprogram，它由一个带有主类的jar文件和几个支持jar文件（作业所需的附加库）组成。
2条答案
按热度按时间kmb7vmvb1#
你可以看看这个测试类clienttest.java，也许能帮到你，更多配置参数请看配置。
f2uvfpb92#
对。根据要连接的集群类型，clusterclient有几种实现(https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/client/program/clusterclient.html).
它可以以阻塞（同步）或分离（异步）方式运行作业。部署作业的一种方法是提供一个packagedprogram，它由一个带有主类的jar文件和几个支持jar文件（作业所需的附加库）组成。