Flink 代碼方式提交程序到遠程集羣運行

在學習Flink時候,看到以下方法,能夠獲取到遠程集羣上的一個ExecutionEnvironment實例,便嘗試使用一下,將本地IDE做業提交到集羣運行,代碼以下:html def createRemoteEnvironment(host: String, port: Int, jarFiles: String*): ExecutionEnvironment 代碼: package com.da
相關文章
相關標籤/搜索