问答 2024-06-08 来自:开发者社区

Flink报错The object you specified is immutable

Flink报错The object you specified is immutable

文章 2024-02-26 来自:开发者社区

在Flink实时任务中,POJO(Plain Old Java Object)对象的模式演进可能会引起不兼容的问题

在Flink实时任务中,POJO(Plain Old Java Object)对象的模式演进可能会引起不兼容的问题,特别是在对已有类进行修改并新增字段后,如果尝试使用新的POJO类从保存点恢复作业时,可能会遇到状态迁移或序列化方面的错误。面对这样的问题,可以采取以下几种方法进行处理: ...

问答 2023-10-10 来自:开发者社区

请问mongoDB中的Object类型在flink中应该映射成什么类型?

请问mongoDB中的Object类型在flink中应该映射成什么类型?然后我想获取某个key的value应该怎么获取?

问答 2023-07-31 来自:开发者社区

请问一下flink1.17.1版本使用内置函数JSON_OBJECT 怎么会拒绝连接的?

请问一下flink1.17.1版本使用内置函数JSON_OBJECT 怎么会拒绝连接的?

文章 2022-08-22 来自:开发者社区

Flink - The object probably contains or references non serializable fields 无法序列化问题

一.引言使用 Flink 自定义 Source 生成数据时,集群提交任务时显示 org.apache.log4j.Logger@72c927f1 is not serializable. The object probably contains or references non serializable fields. 报错序列化相关错误 :编辑二.问题解决1.Scala Class 初始化不....

Flink - The object probably contains or references non serializable fields 无法序列化问题
问答 2022-07-12 来自:开发者社区

请问flink中object的类型对应flink types中的哪个呢

请问flink中object的类型对应flink types中的哪个呢

问答 2021-12-07 来自:开发者社区

有没有办法把flink Row类转换为Object

基于flink做二次开发中,需要将flink SQL执行结果打印到会话中,会话中执行结果打印流程固定打印List类型数据。 大部分查询引擎(比如presto)都会在ResultSet中提供getObject方法,flink中如何实现?*来自志愿者整理的flink邮件归档

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等