Thanks Hequn! On Thu, 30 Aug 2018 at 04:49, Hequn Cheng <[email protected]> wrote:
> Hi Alex, > > It seems a bug. There is a discussion here > <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Kryo-Exception-td20324.html> > . > Best, Hequn > > On Wed, Aug 29, 2018 at 10:19 PM Alexander Smirnov < > [email protected]> wrote: > >> Hi, >> >> A job fell into a restart loop with the following exception. Is it >> something known? >> What could cause it? >> >> Flink 1.4.2 >> >> 16 Aug 2018 13:43:00,835 INFO org.apache.flink.runtime.taskmanager.Task - >> Source: Custom Source -> (Filter -> Timestamps/Watermarks -> Map, Filter -> >> Timestamps/Watermarks -> Flat Map) (1/1) (4306448a2c99603e3e19304357158d12) >> switched from RUNNING to FAILED. >> java.lang.IllegalStateException: Could not initialize operator state >> backend. >> at >> org.apache.flink.streaming.api.operators.AbstractStreamOperator.initOperatorState(AbstractStreamOperator.java:301) >> at >> org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:248) >> at >> org.apache.flink.streaming.runtime.tasks.StreamTask.initializeOperators(StreamTask.java:692) >> at >> org.apache.flink.streaming.runtime.tasks.StreamTask.initializeState(StreamTask.java:679) >> at >> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:253) >> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718) >> at java.lang.Thread.run(Thread.java:748) >> Caused by: com.esotericsoftware.kryo.KryoException: >> java.lang.IndexOutOfBoundsException: Index: 54, Size: 1 >> Serialization trace: >> topic >> (org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition) >> at >> com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:125) >> at >> com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:528) >> at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:761) >> at >> org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer.deserialize(KryoSerializer.java:249) >> at >> org.apache.flink.api.java.typeutils.runtime.TupleSerializer.deserialize(TupleSerializer.java:136) >> at >> org.apache.flink.api.java.typeutils.runtime.TupleSerializer.deserialize(TupleSerializer.java:30) >> at >> org.apache.flink.runtime.state.DefaultOperatorStateBackend.deserializeStateValues(DefaultOperatorStateBackend.java:584) >> at >> org.apache.flink.runtime.state.DefaultOperatorStateBackend.restore(DefaultOperatorStateBackend.java:399) >> at >> org.apache.flink.streaming.runtime.tasks.StreamTask.createOperatorStateBackend(StreamTask.java:733) >> at >> org.apache.flink.streaming.api.operators.AbstractStreamOperator.initOperatorState(AbstractStreamOperator.java:299) >> ... 6 more >> Caused by: java.lang.IndexOutOfBoundsException: Index: 54, Size: 1 >> at java.util.ArrayList.rangeCheck(ArrayList.java:653) >> at java.util.ArrayList.get(ArrayList.java:429) >> at >> com.esotericsoftware.kryo.util.MapReferenceResolver.getReadObject(MapReferenceResolver.java:42) >> at com.esotericsoftware.kryo.Kryo.readReferenceOrNull(Kryo.java:805) >> at com.esotericsoftware.kryo.Kryo.readObjectOrNull(Kryo.java:728) >> at >> com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:113) >> ... 15 more >> >
