admin管理员组

文章数量:1594235

问题

Error:(54, 16) type mismatch;
 found   : org.apache.flink.streaming.api.scala.OutputTag[String]
 required: org.apache.flink.util.OutputTag[Any]
Note: String <: Any, but Java-defined class OutputTag is invariant in type T.
You may wish to investigate a wildcard type such as `_ <: Any`. (SLS 3.2.10)
    ctx.output(tag, value.tempature)

解决

OutputTag的类型应该和侧输出流中的类型保持一致，
若侧输出流输出类型为Double，则OutputTag中的类型均为Double
如下：

lazy val tag: OutputTag[Double] = new OutputTag[Double]

本文标签： 错误typemismatch

版权声明：本文标题：侧输出流中的type mismatch错误解决 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://www.elefans.com/dianzi/1728179066a1148222.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。