?????? ??????savepoint???????????? migration for MapState currently isn't supported.

Thu, 14 Nov 2019 18:10:34 -0800 

????????????????????????????schema??????????????




------------------ ???????? ------------------
??????:&nbsp;"Congxian Qiu"<[email protected]&gt;;
????????:&nbsp;2019??11??15??(??????) ????10:07
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: ??????savepoint???????????? migration for MapState currently 
isn't supported.



Hi
???????? MapState ?? migration ???????????????????????? 1.9??1.9 ?????? 
MapState ?? value schema
evolution[1]

[1] https://issues.apache.org/jira/browse/FLINK-11947
Best,
Congxian


claylin <[email protected]&gt; ??2019??11??14?????? ????9:35??????

&gt; 
??savepoint??????????????????????????????1.8.1??????????????????????????????
&gt; java.lang.RuntimeException: Error while getting state&nbsp;&nbsp; at
&gt; 
org.apache.flink.runtime.state.DefaultKeyedStateStore.getMapState(DefaultKeyedStateStore.java:119)
&gt;&nbsp; at
&gt; 
org.apache.flink.streaming.api.operators.StreamingRuntimeContext.getMapState(StreamingRuntimeContext.java:179)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
com.yy.kafka.template.job.PushServerRspStatisticsVer3$DistinctProcessFunction.open(PushServerRspStatisticsVer3.java:243)
&gt;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
&gt; at
&gt; 
org.apache.flink.streaming.api.operators.KeyedProcessOperator.open(KeyedProcessOperator.java:57)
&gt;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:424)
&gt;&nbsp;&nbsp; at
&gt; 
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:290)
&gt;&nbsp;&nbsp;&nbsp;&nbsp; at 
org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)
&gt;&nbsp; at java.lang.Thread.run(Thread.java:748) Caused by:
&gt; org.apache.flink.util.StateMigrationException: The new serializer for a
&gt; MapState requires state migration in order for the job to proceed. However,
&gt; migration for MapState currently isn't 
supported.&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.migrateStateValues(RocksDBKeyedStateBackend.java:543)
&gt;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.updateRestoredStateMetaInfo(RocksDBKeyedStateBackend.java:525)
&gt;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.tryRegisterKvStateInformation(RocksDBKeyedStateBackend.java:475)
&gt;&nbsp; at
&gt; 
org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.createInternalState(RocksDBKeyedStateBackend.java:613)
&gt;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.runtime.state.ttl.TtlStateFactory.createTtlStateContext(TtlStateFactory.java:197)
&gt;&nbsp; at
&gt; 
org.apache.flink.runtime.state.ttl.TtlStateFactory.createMapState(TtlStateFactory.java:155)
&gt; at
&gt; 
org.apache.flink.runtime.state.ttl.TtlStateFactory.createState(TtlStateFactory.java:126)
&gt;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.runtime.state.ttl.TtlStateFactory.createStateAndWrapWithTtlIfEnabled(TtlStateFactory.java:71)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.runtime.state.AbstractKeyedStateBackend.getOrCreateKeyedState(AbstractKeyedStateBackend.java:286)
&gt;&nbsp; at
&gt; 
org.apache.flink.runtime.state.AbstractKeyedStateBackend.getPartitionedState(AbstractKeyedStateBackend.java:335)
&gt;&nbsp;&nbsp;&nbsp; at
&gt; 
org.apache.flink.runtime.state.DefaultKeyedStateStore.getPartitionedState(DefaultKeyedStateStore.java:124)
&gt;&nbsp; at
&gt; 
org.apache.flink.runtime.state.DefaultKeyedStateStore.getMapState(DefaultKeyedStateStore.java:116)
&gt;&nbsp; ... 9 more

回复