flink keySelector错误

来源：2-10 基于Flink开发第一个实时处理案例之功能实现三

begin_0002

2022-03-04

图片描述
G:\大数据学习\课件资料\Flink实时数据流处理\flink-project\flink-base\src\main\scala\com\hnyd\StreamingWcApp.scala:28:20
overloaded method value keyBy with alternatives:
[K](fun: org.apache.flink.api.java.functions.KeySelector[(String, Int),K])(implicit evidence$3: org.apache.flink.api.common.typeinfo.TypeInformation[K])org.apache.flink.streaming.api.scala.KeyedStream[(String, Int),K]
K => K)(implicit evidence$2: org.apache.flink.api.common.typeinfo.TypeInformation[K])org.apache.flink.streaming.api.scala.KeyedStream[(String, Int),K]
(firstField: String,otherFields: String*)org.apache.flink.streaming.api.scala.KeyedStream[(String, Int),org.apache.flink.api.java.tuple.Tuple]
(fields: Int*)org.apache.flink.streaming.api.scala.KeyedStream[(String, Int),org.apache.flink.api.java.tuple.Tuple]
cannot be applied to (org.apache.flink.api.java.functions.KeySelector[(String, Integer),String])
}).map((_, 1)).keyBy(new KeySelector[(String,Integer),String] {