回答

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文件(專門用於該作業的附加庫)組成。

+0

但我沒有在ClusterClient中看到指定JobManager地址的任何方法。你能告訴我如何指定地址嗎? – Hao

相關問題