You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Scott Kidder (JIRA)" <ji...@apache.org> on 2017/01/26 16:39:24 UTC
[jira] [Closed] (FLINK-5649) KryoException when starting job from
Flink 1.2.0 rc0 savepoint
[ https://issues.apache.org/jira/browse/FLINK-5649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Scott Kidder closed FLINK-5649.
-------------------------------
Resolution: Fixed
Yes, we can close the issue since there's no expectation of compatibility across release-candidates.
> 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)