1.导入依赖

        <!--  flink Web UI -->
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-runtime-web_2.11</artifactId>
            <version>${flink.version}</version>
            <scope>compile</scope>
        </dependency>

2.创建环境指定

        Configuration conf = new Configuration();
        StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf);

3.Web UI 查看地址

flink webui监听地址如下: http://localhost:8081

相关文章:

  • 2021-04-21
  • 2021-10-01
  • 2021-11-05
  • 2021-04-28
  • 2021-12-23
  • 2021-12-23
  • 2021-12-14
  • 2021-10-06
猜你喜欢
  • 2021-09-13
  • 2022-12-23
  • 2022-12-23
  • 2021-07-15
  • 2022-12-23
  • 2022-12-23
相关资源
相似解决方案