如题所述
每个Flink应用程序都需要一个执行环境。流应用程序需要使StreamExecutionEnvironment。在应用程序中进行的DataStream API调用会生成一个作业图，该作业图附加到 StreamExecutionEnvironment。