从ide运行flink时,如何启动flink作业管理器web界面

qnzebej0  于 2021-06-24  发布在  Flink
关注(0)|答案(2)|浏览(481)

我想在从ide本地启动flink web界面时访问它。
我需要这个,因为我想访问flink的计数器(累加器)。

zd287kbt

zd287kbt1#

除了上面答案中的代码之外,pom文件中还需要以下依赖项。

<dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
        <version>${flink.version}</version>
    </dependency>
nsc4cvqm

nsc4cvqm2#

为了在本地启动flink时启动web界面,我们必须在 FlinkMiniCluster . 这个 FlinkMiniCluster 是本地管理所有flink服务启动的类。
包括依赖项:

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
  <version>${flink.version}</version>
</dependency>

下面的代码段将启用 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);

相关问题