十三、Flink使用local模式执行任务并开启Flink的webUI-Toy模板网

这篇具有很好参考价值的文章主要介绍了十三、Flink使用local模式执行任务并开启Flink的webUI。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

1、概述

1）webUI依赖

      <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
             <version>${flink.version}</version>
        </dependency>

2）调用StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration);

3）可以通过configuration配置webUI的端口号

2、代码实现

import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.datastream.DataStreamSink;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class LocalWebUI {
    public static void main(String[] args) throws Exception {
        // 创建本地执行环境，并设置 webUI 参数
        Configuration configuration = new Configuration();
        configuration.setInteger("rest.port", 8081);

        // 创建一个带 webUI 的本地执行环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(configuration);

        // 从端口接入数据
        DataStreamSource<String> lines = env.socketTextStream("localhost", 8888);

        // 使用map方法对输入的单词转为大写
        SingleOutputStreamOperator<String> uppered = lines.map(line -> line.toUpperCase());

        DataStreamSink<String> print = uppered.print();

        env.execute();
    }
}