【Flink】问题整理二、flink1.12版本

一、Exception in thread "main" java.lang.IllegalStateException: No ExecutorFactory found to execute the application.

添加 flink-client客户端


  org.apache.flink
  flink-clients_2.12
  1.12.0

二、java.lang.ClassNotFoundException: org.apache.flink.api.common.typeinfo.TypeInformation

引入隐式转换

import org.apache.flink.streaming.api.scala._

按装的scala版本要和pom文件的scala版本一致 2.11

 
      org.apache.flink
      flink-streaming-scala_2.11
      1.12.0
      provided

以及加大范围的选择

三、这就算是启动成功了

执行也ok

Flink

相关