我希望在从IDE本地启动Flink时能够访问Flink Web界面。
我需要这样做是因为我想要访问Flink的计数器(累加器)。
我希望在从IDE本地启动Flink时能够访问Flink Web界面。
我需要这样做是因为我想要访问Flink的计数器(累加器)。
FlinkMiniCluster
中启用Web界面。 FlinkMiniCluster
是管理所有本地Flink服务启动的类。<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>
以下代码段将为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);
在 Flink 的新版本中,ConfigConstants.LOCAL_START_WEBSERVER
已经被弃用。 相反,您可以使用以下内容:
StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(new Configuration());
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime-web</artifactId>
<version>${flink.version}</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
</dependency>