在本地调试时希望启动Flink Web UI 查看DAG图,watermark等信息,那么该如何做呢?
引入 Flink Web UI 的依赖org.apache.flink flink-runtime-web_${scala.binary.version}. ${flink.version}
本文使用的 Flink 版本为1.12.0
创建带有 WebUI 的本地运行环境Configuration configuration = new Configuration();
configuration.setString("rest.port","9091"); //指定 Flink Web UI 端口为9091
StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration);
env.execute("FlinkWebUITest");
进入 Flink WebUI
浏览器打开该地址:http://localhost:9091



