[
https://issues.apache.org/jira/browse/FLINK-5649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15839863#comment-15839863
]
Aljoscha Krettek commented on FLINK-5649:
-----------------------------------------
As [~uce] mentioned on the mailing lists this is a by-product of fixing the
Kryo Serializer to work when restoring from Flink 1.1 savepoints. Is this an
actual problem for you or did you just stumble across in your testing? If not,
I think we can close this issue.
> KryoException when starting job from Flink 1.2.0 rc0 savepoint
> --------------------------------------------------------------
>
> Key: FLINK-5649
> URL: https://issues.apache.org/jira/browse/FLINK-5649
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.2.0
> Reporter: Scott Kidder
>
> I tried to submit a job using a savepoint taken with Flink 1.2.0 rc0 and
> encountered the following error on Flink 1.2.0 rc2, leading to the job being
> cancelled:
> {noformat}
> java.lang.IllegalStateException: Could not initialize keyed state backend.
> at
> org.apache.flink.streaming.api.operators.AbstractStreamOperator.initKeyedState(AbstractStreamOperator.java:286)
> at
> org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:199)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.initializeOperators(StreamTask.java:663)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.initializeState(StreamTask.java:650)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:256)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: com.esotericsoftware.kryo.KryoException: Encountered unregistered
> class ID: 92
> at
> com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(DefaultClassResolver.java:119)
> at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
> at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:752)
> at
> org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.deserialize(KryoSerializer.java:232)
> at
> org.apache.flink.api.java.typeutils.runtime.PojoSerializer.deserialize(PojoSerializer.java:414)
> at
> org.apache.flink.api.java.typeutils.runtime.PojoSerializer.deserialize(PojoSerializer.java:414)
> at
> org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.readStateTableForKeyGroup(HeapKeyedStateBackend.java:370)
> at
> org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.restorePartitionedState(HeapKeyedStateBackend.java:340)
> at
> org.apache.flink.runtime.state.heap.HeapKeyedStateBackend.restore(HeapKeyedStateBackend.java:243)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.createKeyedStateBackend(StreamTask.java:798)
> at
> org.apache.flink.streaming.api.operators.AbstractStreamOperator.initKeyedState(AbstractStreamOperator.java:277)
> ... 6 more
> {noformat}
> Submitting the same job without a savepoint works fine (except that there's
> no state, of course).
> Might be related to FLINK-5484 pull-request
> https://github.com/apache/flink/pull/3152
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
