解决 scala - Apache Flink Streaming 的 type mismatch in flatMap function

当我使用Flink 为1.7.2,Scala为2.11时,使用Flatmap函数时会报错 点进去Flatmap查看代码时发现,系统自动导入的时java的代码 解决办法 只需要导入 org.apache.flink.streaming.api.scala.StreamExecutionEnvironment. 即可
相关文章
相关标签/搜索