赞
踩
在本地调试时希望启动Flink Web UI 查看DAG图,watermark等信息,那么该如何做呢?
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-runtime-web_2.11</artifactId>
<version>1.12.4</version>
</dependency>
Configuration configuration = new Configuration();
//指定 Flink Web UI 端口为9091
configuration.setInteger("rest.port", 9091);
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment(configuration);
env.execute("FlinkWebUI");
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。