我知道喬布斯可以通過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