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 <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> 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. >> >
