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.
>>
>
erator 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/>.
>>
>
ate-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.
ysql.
--
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.
.run(Task.java:655)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.io.StreamCorruptedException: invalid type code: 00
> at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1381)
> at java.io.ObjectInputStream.readObject(ObjectInputStream.java
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:257)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.io.StreamCorruptedException: invalid type code: 00
at
