flink在本地idea调试出现webUI

添加maven依赖&＃xff1a;

org.apache.flinkflink-runtime-web_2.111.8.0



关键代码&＃xff1a;

import org.apache.flink.configuration.ConfigConstants;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.configuration.TaskManagerOptions;Configuration cfg &＃61; new Configuration();
cfg.setBoolean(ConfigConstants.LOACAL_START_WEBSERVER, true);
cfg.setInteger(TaskManagerOptions.NUM_TASK_SLOTS, 6);
final StreamExecutionEnvironment env &＃61; StreamExecutionEnvironment.createExecutionEnvironment.createLocalEnvironmentWithWebUI(cfg).enableCheckpointing(10000);


运行后&＃xff0c;浏览器打开http://localhost:8081/ 即可