Fwd: invalid type code: 00

[Kostas Kloudas]

I am forwarding Stefan’s reply here:

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.