各位大佬,我这么设置反序列化器,遇到了空指针异常,想问下解决这个异常,反序列化器该怎么设置

各位大佬,我这么设置反序列化器,遇到了空指针异常,想问下解决这个异常,反序列化器该怎么设置 f789235ec627ee72d5a329f8a8bce717.png

展开
收起
十一0204 2023-04-11 09:08:36 274 分享 版权
2 条回答
写回答
取消 提交回答
  • 意中人就是我呀!

    你一开始完全表达反了。 if 里面补全 (record != null && record.value() != null) 这样 value即使是空值 出来就是null,后面再过滤掉 此答案整理自钉群“【③群】Apache Flink China社区”

    2023-04-12 08:47:42
    赞同 展开评论
  • 发表文章、提出问题、分享经验、结交志同道合的朋友

    在Java语言中,可以使用Jackson、Gson等库进行反序列化操作,定义反序列化器,例如:

    ObjectMapper mapper = new ObjectMapper();
    mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
    MyObject obj = mapper.readValue(jsonString, MyObject.class);
    
    2023-04-11 09:19:22
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
还有其他疑问?
咨询AI助理