我知道乔布斯可以通过flink或flink.bat提交给JobManager。我想知道Flink是否提供Java API将作业提交给JobManager?Flink是否提供Java API以将作业提交给JobManager?
1
A
回答
2
是的。根据您要连接的群集类型,有几种ClusterClient实现(https://ci.apache.org/projects/flink/flink-docs-release-1.3/api/java/org/apache/flink/client/program/ClusterClient.html)。
它可以以阻塞(同步)或分离(异步)方式运行作业。部署作业的一种方式是提供一个PackagedProgram,它由一个带有主类的JAR文件和几个支持的JAR文件(专门用于该作业的附加库)组成。
1
相关问题
- 1. 是否可以将批处理作业提交给deezer API?
- 2. 将flink作业提交到远程virtualbox不起作用
- 3. 是否可以手动将GoogleCredential提供给SpeechClient(在.NET API中)?
- 4. 如何将Flink作业提交到远程YARN集群?
- 5. 作业提交在星火作业服务器提供的NullPointerException
- 6. flink是否支持暂停flink作业?
- 7. 是否可以给GridView提供动画?
- 8. 加载大文件时Flink作业在提交时挂起
- 9. 提交Hadoop作业
- 10. YARN REST API - Spark作业提交
- 11. Dataproc:通过REST API提交Spark作业
- 12. Hadoop HDInsight .NET SDK API提交作业
- 13. 如何仅将密码提交给heroku而不提供给github?
- 14. 是否可以使用Twitter API将推文提供给本地文本文件?
- 15. 为gcloud作业提供解密密钥提交培训
- 16. Orbitz.com是否提供用于集成的商业API?
- 17. Ylink上的Flink JobManager是否需要Zookeeper进行HA设置
- 18. 是否可以编写一个将Java类提供给JVM的C/C++程序?
- 19. 如何提交flink作业,而不是使用他们的仪表板?
- 20. 完成作业后提交批作业
- 21. 如何将cookie提供给Java HTMLDocument?
- 22. 是否可以将数据从excel工作表中提供给chartist.js?
- 23. Rabbit MQ是否提供SOAP API?
- 24. Google代码是否提供API?
- 25. 谷歌是否提供搜索API
- 26. RequireJS是否提供了依赖API?
- 27. Citrus Pay是否提供REST API?
- 28. Atmospherejs是否提供任何API?
- 29. LinkedIn是否提供离线访问API?
- 30. WordPress是否提供搜索API
但我没有在ClusterClient中看到指定JobManager地址的任何方法。你能告诉我如何指定地址吗? – Hao