我想在从ide本地启动flink web界面时访问它。我需要这个,因为我想访问flink的计数器(累加器)。
zd287kbt1#
除了上面答案中的代码之外,pom文件中还需要以下依赖项。
<dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-runtime-web_${scala.binary.version}</artifactId> <version>${flink.version}</version> </dependency>
nsc4cvqm2#
为了在本地启动flink时启动web界面,我们必须在 FlinkMiniCluster . 这个 FlinkMiniCluster 是本地管理所有flink服务启动的类。包括依赖项:
FlinkMiniCluster
下面的代码段将启用 StreamExecutionEnvironment :
StreamExecutionEnvironment
// set up the execution environment Configuration conf = new Configuration(); conf.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true); final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment(8, conf);
您还可以使用restoptions配置服务器:
conf.setInteger(RestOptions.PORT, 8082);
2条答案
按热度按时间zd287kbt1#
除了上面答案中的代码之外,pom文件中还需要以下依赖项。
nsc4cvqm2#
为了在本地启动flink时启动web界面,我们必须在
FlinkMiniCluster
. 这个FlinkMiniCluster
是本地管理所有flink服务启动的类。包括依赖项:
下面的代码段将启用
StreamExecutionEnvironment
:您还可以使用restoptions配置服务器: