【发布时间】:2018-12-11 04:08:20
【问题描述】:
我想在从 IDE 本地启动时访问 Flink Web 界面。
我需要这个,因为我想访问 Flink 的计数器(累加器)。
【问题讨论】:
标签: apache-flink
我想在从 IDE 本地启动时访问 Flink Web 界面。
我需要这个,因为我想访问 Flink 的计数器(累加器)。
【问题讨论】:
标签: apache-flink
为了在本地启动 Flink 时启动 web 界面,我们必须在FlinkMiniCluster 中启用 web 界面。 FlinkMiniCluster 是管理本地所有 Flink 服务启动的类。
包含依赖:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>
以下 sn-p 将为 StreamExecutionEnvironment 启用 Web 界面:
// 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);
除了上面回答中的代码,pom文件中还需要如下依赖。
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>
【讨论】: