I am forwarding Stefan’s reply here:
> Hi,
>
> this problem can be caused by
> https://issues.apache.org/jira/browse/FLINK-6044
> <https://issues.apache.org/jira/browse/FLINK-6044>. It is fixed in 1.2.1 and
> 1.3.
>
> Best,
> Stefan
>
>> Am 26.05.2017 um 16:16 schrieb Kostas Kloudas <k.klou...@data-artisans.com
>> <mailto:k.klou...@data-artisans.com>>:
>>
>> Hi,
>>
>> Could you provide some info on when is this error happening?
>>
>> From what I see you are using the heap or fs state backend and you are
>> failing to read the state back when restoring from a failure. The failure
>> can
>> be unrelated to this, but it could be useful if you could check the task
>> manager
>> logs to see why the failure happens and if there are any exceptions when
>> checkpointing
>> for example.
>>
>> Also could you share the code for your objects (what you are serializing)?
>> Just to cover some cases.
>>
>> I aslo include Stefan in this.
>>
>> Kostas
>>
>>> On May 26, 2017, at 1:06 PM, rhashmi <rizhas...@hotmail.com
>>> <mailto:rizhas...@hotmail.com>> wrote:
>>>
>>> Which Flink version you are using? 1.2
>>> What is your job doing (e.g. operators that you are using)? ProcessFunction
>>> to determine if event is late change event time to current & then window
>>> Which operator throws this exception? i will have to dig it further
>>> Which state-backend are you using? mysql.
>>>
>>>
>>>
>>> --
>>> View this message in context:
>>> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/invalid-type-code-00-tp13326p13332.html
>>>
>>> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/invalid-type-code-00-tp13326p13332.html>
>>> Sent from the Apache Flink User Mailing List archive. mailing list archive
>>> at Nabble.com <http://nabble.com/>.
>>
>
