flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "shao.hongxiao" <17611022...@163.com>
Subject 回复:flink1.9,state process api 读取MapState,出错
Date Thu, 30 Apr 2020 07:19:18 GMT


用一个正常的Java pojo试一下
| |
邵红晓
|
|
邮箱:17611022895@163.com
|
签名由网易邮箱大师定制
在2020年4月30日 15:14,guanyq<dlguanyq@163.com> 写道:
有没有发现,我这还是报错。

















在 2020-04-30 09:40:45,"shx" <17611022895@163.com> 写道:
能发一下写入状态的代码看一下吗,还有一个问题,键值状态访问,你的代码里是读出了所有key关键的mapstate吗,谢谢




| |
邵红晓
|
|
邮箱:17611022895@163.com
|

签名由 网易邮箱大师 定制

在2020年04月30日 09:04,guanyq 写道:
代码中没特别指定Serializer。都是默认的序列化。
在 2020-04-29 18:20:22,"Congxian Qiu" <qcx978132955@gmail.com> 写道:
Hi
从错误日志看,是 StateMigration 相关的问题。
你需要确认下,你的代码中的 Serializer 和 savepoint 中 state 相关的 serializer
是一样的或者是兼容的,你可以参考下这个文档[1]

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/state/schema_evolution.html

Best,
Congxian


guanyq <dlguanyq@163.com> 于2020年4月29日周三 下午6:09写道:


附件是代码和错误日志。目前不知道如何调查。麻烦帮忙看下 谢谢。
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message