[
https://issues.apache.org/jira/browse/FLINK-4760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenzhong Xu updated FLINK-4760:
--------------------------------
Summary: Kafka 09 Consumer failed to initialize state because of corrupted
operator state and not able to recover (was: Kafka 09 Consumer failed to
initialize state causing job to restart)
> Kafka 09 Consumer failed to initialize state because of corrupted operator
> state and not able to recover
> --------------------------------------------------------------------------------------------------------
>
> Key: FLINK-4760
> URL: https://issues.apache.org/jira/browse/FLINK-4760
> Project: Flink
> Issue Type: Bug
> Components: Kafka Connector, State Backends, Checkpointing
> Reporter: Zhenzhong Xu
> Priority: Critical
>
> java.io.StreamCorruptedException: invalid stream header: 02000078
> at
> java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:806)
> at java.io.ObjectInputStream.<init>(ObjectInputStream.java:299)
> at
> org.apache.flink.api.java.typeutils.runtime.JavaSerializer.deserialize(JavaSerializer.java:79)
> at
> org.apache.flink.api.java.typeutils.runtime.JavaSerializer.deserialize(JavaSerializer.java:31)
> at
> org.apache.flink.runtime.state.DefaultOperatorStateBackend.getPartitionableState(DefaultOperatorStateBackend.java:107)
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.initializeState(FlinkKafkaConsumerBase.java:323)
> at
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:105)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:396)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:269)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:608)
> at java.lang.Thread.run(Thread.java:745)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
