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
网友评论