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 f
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/
flink版本使用1.12.2，业务需要用到了侧输出流，首先先创建了一个侧输出标签
val outputTagDate = OutputTag[String]("Date-side-output")。程序写完编译的时候报
type mismatch :
found : org.apache.flink.streaming.api.scala.OutputTag[String]
required: org.apache.flink.util.OutputTag[java.io.Serializable]
Note: String <: java.io.Serializable, but
