Hi Sridhar, Sorry that this didn't get a response earlier.
According to the trace, it seems like the job failed during the process, and when trying to automatically restore from a checkpoint, deserialization of a CEP `IterativeCondition` object failed. As far as I can tell, CEP operators are just using Java serialization on CEP `IterativeCondition` objects, so should not be related to the protobuf serializer that you are using. Is this still constantly happening for you? Cheers, Gordon -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
