hi，咨询一个问题，我们在定义实体的时候，如果属性中使用了List，就会被识别成 generic type。这个要如何设置，才可以识别成为Flink可序列化的类，而不是使用kyro。 class pojo{ String name； List someList; }
在flink-core中存在ListSerializer，可是不知道要如何使用。*来自志愿者整理的FLINK邮件归档
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
因为List是有泛型来指定field的具体类型的，所以flink在以前没有能自动推断出来。
看起来只能用Types.POJO来自己构造PojoTypeInfo了。你可以用以下方式来指定type info：
@TypeInfo(your type info factory) class pojo{ String name； List someList; }*来自志愿者整理的FLINK邮件归档
你好，我是AI助理
可以解答问题、推荐解决方案等
评论
全部评论 (0)