开发者社区> 问答> 正文

flink 侧输出流类型怎么转换呀?

flink版本使用1.12.2,业务需要用到了侧输出流,首先先创建了一个侧输出标签 val outputTagDate = OutputTagString。程序写完编译的时候报 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 Java-defined class OutputTag is invariant in type T. You may wish to investigate a wildcard type such as _ <: java.io.Serializable. (SLS 3.2.10) ctx.output(outputTagDate, Date(first_retain,noob_endtime,noob_first_endtime)) 之后我修改了包名 import org.apache.flink.util.{OutputTag =>CommOutputTag} 然后重新创建 val outputTagDate = new CommOutputTag String 但是后面从测流中取时 val dateDS: DataStream[String] = ds.getSideOutput(outputTagDate) 报错。还是报type.,mismatch, required: org.apache.flink.streamiing.api.scala.OutputTag[NotInferedX] found: org.apache.flink.util.OutputTag [String] outputTagDate这个变量怎么一会儿需要 org.apache.flink.streaming.api.scala.OutputTag 一会儿又要 org.apache.flink.util.OutputTag呢。 为啥会这样呢,这块应该怎么书写呢?*来自志愿者整理的FLINK邮件归档```js

展开
收起
又出bug了-- 2021-12-03 16:37:00 856 0
1 条回答
写回答
取消 提交回答
  • Date是case class ,后面加了tostring()就好了*来自志愿者整理的FLINK邮件归档

    2021-12-03 17:43:32
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载