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/

回复