Flink-1.10升级到Flink1.12的问题

一、代码gitee地址 二、问题 1、No operators defined in streaming topology. Cannot generate StreamGraph.

代码结构

  //使用Flink原生的代码创建TableEnvironment
  //先初始化流计算的上下文
  val streamEnv: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
  val settings: EnvironmentSettings = EnvironmentSettings.newInstance().useOldPlanner().inStreamingMode().build()
  val tableEnv: StreamTableEnvironment = StreamTableEnvironment.create(streamEnv, settings)
  ......
  tableEnv.execute("group")

Flink1.11版本对于两个env的execute代码实现有改动，在1.11后的版本里需要用

streamEnv.execute("group")

2、No ExecutorFactory found to execute the application

经查，原因是：从Flink1.11开始，移除了flink-streaming-java对flink-clients的依赖，需要手动加入clients依赖。

3、下载Flink1.12版本源码，报错无效的源发行版: 11 和 无效的目标发行版：11 解决方法

报错原因： 编译器中的jdk版本不符。

• File→Settings→Build,Execution,Deployment→Java Complier

统一修改