[jira] [Created] (FLINK-4760) Kafka 09 Consumer failed to initialize state causing job to restart

[Zhenzhong Xu (JIRA)]

Zhenzhong Xu created FLINK-4760:
-----------------------------------

             Summary: Kafka 09 Consumer failed to initialize state causing job 
to restart
                 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)