我知道乔布斯可以通过flink或flink.bat向flink.bat提交。我想知道Flink是否提供Java来向JobManager提交作业?
发布于 2017-08-20 10:15:02
是。根据要连接的集群类型,有几个ClusterClient (https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/client/program/ClusterClient.html)实现。
它可以以阻塞(同步)或分离(异步)的方式运行作业。部署作业的一种方法是提供一个PackagedProgram,它由一个包含一个主类的JAR文件和几个支持JAR文件组成(作业需要额外的库)。
发布于 2017-08-21 09:00:50
您可以查看这个测试类ClientTest.java,可能可以帮助您,更多的配置参数见配置。
https://stackoverflow.com/questions/45769652
复制相似问题