Type mismatch, expected: ProcessWindowFunction[(String, String), NotInferedR, String, TimeWindow], actual: ProcessWindowFunction
- 使用scala编码
- 解决引入包有问题,将引入了flink java api 的包
org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction
改为
import org.apache.flink.streaming.api.scala.function.ProcessWindowFunction
网友评论