Re:Re:回复：flink1.9,state process api 读取MapState，出错

Thu, 30 Apr 2020 00:52:32 -0700 

我自己又实现了一个MapState的存储job，用同样的代码是可以读取出所有MapState的key的。
在 2020-04-30 15:23:39，"guanyq" <[email protected]> 写道：
>public class MyKeyedMapState {<br/>    public String key;<br/>    public 
>List&lt;String&gt; value;<br/><br/>    public MyKeyedMapState() {<br/>    
>}<br/><br/>    public String getKey() {<br/>        return key;<br/>    
>}<br/><br/>    public void setKey(String key) {<br/>        this.key = 
>key;<br/>    }<br/><br/>    public List&lt;String&gt; getValue() {<br/>        
>return value;<br/>    }<br/><br/>    public void setValue(List&lt;String&gt; 
>value) {<br/>        this.value = value;<br/>    
>}<br/>}<br/><br/>改成这个也还是报同样的错误！
>在 2020-04-30 15:19:18，"shao.hongxiao" <[email protected]> 写道：
>>
>>
>>用一个正常的Java pojo试一下
>>| |
>>邵红晓
>>|
>>|
>>邮箱：[email protected]
>>|
>>签名由网易邮箱大师定制
>>在2020年4月30日 15:14，guanyq<[email protected]> 写道：
>>有没有发现，我这还是报错。
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>在 2020-04-30 09:40:45，"shx" <[email protected]> 写道：
>>能发一下写入状态的代码看一下吗，还有一个问题，键值状态访问，你的代码里是读出了所有key关键的mapstate吗，谢谢
>>
>>
>>
>>
>>| |
>>邵红晓
>>|
>>|
>>邮箱：[email protected]
>>|
>>
>>签名由 网易邮箱大师 定制
>>
>>在2020年04月30日 09:04，guanyq 写道：
>>代码中没特别指定Serializer。都是默认的序列化。
>>在 2020-04-29 18:20:22，"Congxian Qiu" <[email protected]> 写道：
>>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 <[email protected]> 于2020年4月29日周三 下午6:09写道：
>>
>>
>>附件是代码和错误日志。目前不知道如何调查。麻烦帮忙看下 谢谢。

回复