本地开启webui

  1. Configuration conf = new Configuration();
  2. StreamExecutionEnvironment env = 
  3.     StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(conf);
  1. <dependency>
  2.    <groupId>org.apache.flink</groupId>
  3.    <artifactId>flink-runtime-web_2.11</artifactId>
  4.    <version>${flink.version}</version>
  5. </dependency>

http://127.0.0.1:8081