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

Flink 在什么时候检查算子中对象的序列化?

我想弄明白什么flink在什么时候,哪些情况需要检查序列化,以及哪些对象会被序列化。静态方法又是如何处理的? 有没有仔细研究过这方面,提示一下我怎么看源码或者是如何了解这块。 *来自志愿者整理的flink邮件归档

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

关于flink状态后端使用Rocksdb序列化问题

目前采用flink on yarn, flink版本是1.7.2,hadoop是2.8.5 现在遇到个问题,假设订单对象Order,因使用了窗口等,所以有状态产生,假设现在要在Order中添加几个新的字段,采用savepoint重启任务,就会报错,看错误信息是反序列化问题(rocksdb默认用的kryo), 只能kill掉再重启,导致状态丢失,请问有什么解决办法吗?需求不断变更,肯定会定期增加.....

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

关于flink 读取 jdbc报错详情,序列化报错怎么办?

使用场景:FLink 1.11.1 读取mysql,一直报序列化错误,但感觉需要序列化的bean对象已经序列化,实在百思不得其解,前来求教各位大佬!!! 代码再附件!!! Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: java.util.concurrent.CountDownLa.....

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

要如何设置,List才可以识别成为Flink可序列化的类呢?

hi,咨询一个问题,我们在定义实体的时候,如果属性中使用了List,就会被识别成 generic type。这个要如何设置,才可以识别成为Flink可序列化的类,而不是使用kyro。 class pojo{ String name; List someList; } 在flink-core中存在ListSerializer,可是不知道要如何使用。*来自志愿者整理的FLINK邮件归档

问答 2021-01-06 来自:开发者社区

Flink Pojo 的序列化与反序列化的类型规则是怎样的

Flink Pojo 的序列化与反序列化的类型规则是怎样的

问答 2021-01-06 来自:开发者社区

Flink 序列化过程中,进行序列化操作的序列化器从何而来?

Flink 序列化过程中,进行序列化操作的序列化器从何而来?

问答 2021-01-06 来自:开发者社区

Flink 对于无法序列化的类型是如何处理的

Flink 对于无法序列化的类型是如何处理的

问答 2021-01-06 来自:开发者社区

在 Flink 通信层的序列化中,何时进行真正的序列化 / 反序列化操作?

在 Flink 通信层的序列化中,何时进行真正的序列化 / 反序列化操作?

问答 2021-01-06 来自:开发者社区

在 Flink 通信层的序列化中,何时确定 Function 的序列化 / 反序列化器

在 Flink 通信层的序列化中,何时确定 Function 的序列化 / 反序列化器

问答 2021-01-06 来自:开发者社区

在 Flink 通信层的序列化中,何时确定 Function 的输入输出类型

在 Flink 通信层的序列化中,何时确定 Function 的输入输出类型

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