Re: Failure restarting Flink 1.5.0 job from checkpoint

Thanks for reporting the issue Ken. This looks indeed very strange and we need to investigate how this can happen. Cheers, Till On Thu, May 31, 2018 at 8:07 PM, Ken Krugler wrote: > Hi Aljoscha, > > Yes, looks that way, thanks the issue reference - I’d checked Jira few > days ago, looks like FL

Re: Failure restarting Flink 1.5.0 job from checkpoint

Hi Aljoscha, Yes, looks that way, thanks the issue reference - I’d checked Jira few days ago, looks like FLINK-9458 was added very recently :) I’ll follow up in Jira to see if a small code snippet would be useful. — Ken > On May 31, 2018, at 1:17 AM, Aljoscha Krettek wrote: > > Hi Ken, > >

Re: Failure restarting Flink 1.5.0 job from checkpoint

Hi Ken, I think you might have independently discovered this issue: https://issues.apache.org/jira/browse/FLINK-9458 Best, Aljoscha > On 31. May 2018, at 01:46, Ken Krugler wrote: > > Hi devs, > > I coded up a simple iteration that uses a K

Failure restarting Flink 1.5.0 job from checkpoint

Hi devs, I coded up a simple iteration that uses a KeyedProcessFunction, as a way of showing how to use timers to do state iteration. This worked fine, but then I wanted to try out checkpoints. I modified the KeyedProcessFunction to throw an exception after a fixed number of calls. When this h