flink1.10 本地调试集成webUI

2020-04-16  本文已影响0人  陈雨来

1、pom集成

<dependency>

<groupId>org.apache.flink</groupId>

<artifactId>flink-runtime-web_${scala.version}</artifactId>

<version>${flink.version}</version>

</dependency>

2、调用createLocalEnvironmentWithWebUI

StreamExecutionEnvironment fsEnv = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(new Configuration());

3、启动,访问地址http://localhost:8081

上一篇 下一篇

猜你喜欢

热点阅读