Flink学习第五天——Flink可视化控制台依赖配置和界面介绍

• WebUI可视化界面

  • 访问：ip:8081
  • 方式一：服务端部署Flink集群（生产环境）
  • 方式二：本地依赖添加（测试开发）

       <!--Flink web ui-->
          <dependency>
              <groupId>org.apache.flink</groupId>
              <artifactId>flink-runtime-web_${scala.version}</artifactId>
              <version>${flink.version}</version>
          </dependency>

• 代码开发

      public static void main(String[] args) throws Exception {
  ​
  ​
          final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(new Configuration());
          //env.setParallelism(1);
  ​
          DataStream<String> stringDataStream = env.socketTextStream("127.0.0.1",8888);
  ​
          
          DataStream<String> flatMapDataStream = stringDataStream.flatMap(new FlatM