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

2024-03-30 10:04•css•阅读 3909

当我使用Flink 为1.7.2,Scala为2.11时，使用Flatmap函数时会报错

点进去Flatmap查看代码时发现，系统自动导入的时java的代码

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

解决办法

只需要导入

org.apache.flink.streaming.api.scala.StreamExecutionEnvironment. 即可

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