Flink 代码方式提交程序到远程集群运行

在学习Flink时候,看到以下方法,能够获取到远程集群上的一个ExecutionEnvironment实例,便尝试使用一下,将本地IDE做业提交到集群运行,代码以下:html def createRemoteEnvironment(host: String, port: Int, jarFiles: String*): ExecutionEnvironment 代码: package com.da
相关文章
相关标签/搜索