required: org.apache.flink.streaming.api.scala.function.ProcessWindowFunction[(Long, String, String

Error:(48, 46) not found: type Context override def process(key: String, context: Context, elements: Iterable[(Long, String, String)], out: Collector[String]): Unit = { Error:(36, 16) type mismatch; f

>>阅读原文<<