flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Zhenzhong Xu (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4760) Kafka 09 Consumer failed to initialize state causing job to restart
Date Thu, 06 Oct 2016 22:47:20 GMT
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)

Mime
View raw message