问题描述
env.getConfig.registerTypeWithKryoSerializer(classOf[EventMeta],classOf[ProtobufSerializer[EventMeta]])
其中 EventMeta
是由 scalaPB 从 proto 消息生成的案例类。我们使用 flink 1.10.1 和 scala 2.11。
我试图翻译文档中的 Java 代码:env.getConfig.registerTypeWithKryoSerializer(EventMeta.class,ProtobufSerializer.class)
,但编译器一直告诉我:
overloaded method value registerTypeWithKryoSerializer with alternatives:
[error] (x$1: Class[_],x$2: Class[_ <: com.esotericsoftware.kryo.Serializer[_]])Unit <and>
[error] [T <: com.esotericsoftware.kryo.Serializer[_] with java.io.Serializable](x$1: Class[_],x$2: T)Unit
[error] cannot be applied to (Class[com.here.lanes.laneroadreference.derivation.statefun.state.EventMeta.EventMeta],Class[org.apache.flink.statefun.flink.common.protobuf.ProtobufSerializer[com.here.lanes.laneroadreference.derivation.statefun.state.EventMeta.EventMeta]])
[error] env.getConfig.registerTypeWithKryoSerializer(classOf[EventMeta],classOf[ProtobufSerializer[EventMeta]])
显然,ProtobufSerializer
在我们的 flink 版本中没有扩展 Serializer
。 doc 或 ProtobufSerializer
中是否有错误?我该如何解决这个问题?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)