说明

StreamExecutionEnvironment 是所有Flink程序的基础，要想处理数据，先获取执行环境

有以下3种静态方法

根据上下文获取环境

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

原理：

• 如果提交远程集群的运行，底层调用 下面 获取集群环境 的代码，返回 远程环境

• 如果在本地运行，底层调用 下面 获取本地环境 的代码，返回 本地环境

获取本地环境

StreamExecutionEnvironment.createLocalEnvironment()

默认并行度是 逻辑处理器 的数量

获取集群环境

StreamExecutionEnvironment.createRemoteEnvironment(
            String host,
            int port,
            int parallelism,
            String... jarFiles) // 提交给 JobManager的jar包

选择

一般情况，只需要使用第一种 getExecutionEnvironment()，因为 根据上下文 获取环境

原文出处：/show_1IX1zZwVzSfy.html