我尝试执行以下操作:env.readHadoopFile(newTeraInputFormat(),classOf[Text],classOf[Text],inputPath).map(tp=>tp)但随后我在编辑器中收到类型不匹配错误:Expected:MapFunction[Tuple2[Text,Text],NotInferedR],actual:(Nothing)=>Nothing我该如何解决这个问题？这是完整的代码:importorg.apache.flink.api.common.functions.Partitionerimportorg.apache.flink.api