栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

【FLINK】This type (GenericType) cannot be used as key.

【FLINK】This type (GenericType) cannot be used as key.

背景:flink 1.13.2
           scala 2.11

           在使用flink KeyedProcessFunction函数时,在上一步的keyBy函数里使用fieldName,产生了上面的错误类型,说POJO类型不能做为key

1、类的定义
@Data
@EqualsAndHashCode
public class ClickDataEntity implements Serializable, CommonInter {

    private static final Logger logger = LoggerFactory.getLogger(ClickDataEntity.class);

    private static final long serialVersionUID = -429917380238421788L;


    public String processTime; //后台接收时间
    .....
}
2、解决方案

 2.1 换成Tuple类型,直接使用tuple.f0
 2.2 POJO类型,需要再添加一个无参构造方法

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/434076.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号