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.
