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

Posted 2021-08-22 宝哥大数据

一、代码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依赖。