I am forwarding Stefan’s reply:
Hi,
this problem can be caused by
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 <
[hidden email]>:
>>
>> 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 <
[hidden email]> 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>>> Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
>>
>
Locked
