Date是case class ,我后面加了tostring()就好了 lp <973182...@qq.com> 于2021年4月30日周五 下午5:28写道:
> val outputTagDate = OutputTag[String]("Date-side-output") > 你的outputtag定义的泛型是string > > ctx.output(outputTagDate,Date(first_retain,noob_endtime,noob_first_endtime)) > 这个Date是个什么函数,返回的是string类型么 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >