Flink 是否提供 Java API 向 JobManager 提交作业?
Does Flink provide Java API to submit jobs to JobManager?
我知道Jobs可以通过flink或者flink.bat提交给JobManager。我想知道Flink有没有提供JavaAPI向JobManager提交作业?
是的。根据您要连接的集群类型,ClusterClient 有多种实现方式 (https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/client/program/ClusterClient.html)。
它可以 运行 阻塞(同步)或分离(异步)方式的作业。部署作业的一种方法是提供一个 PackagedProgram,它由一个带有 Main Class 的 JAR 文件和几个支持 JAR 文件(该作业专门需要的其他库)组成。
你可以看看这个测试class ClientTest.java, may be able to help you, more configuration parameters see configuration.
我知道Jobs可以通过flink或者flink.bat提交给JobManager。我想知道Flink有没有提供JavaAPI向JobManager提交作业?
是的。根据您要连接的集群类型,ClusterClient 有多种实现方式 (https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/client/program/ClusterClient.html)。
它可以 运行 阻塞(同步)或分离(异步)方式的作业。部署作业的一种方法是提供一个 PackagedProgram,它由一个带有 Main Class 的 JAR 文件和几个支持 JAR 文件(该作业专门需要的其他库)组成。
你可以看看这个测试class ClientTest.java, may be able to help you, more configuration parameters see configuration.