Hi Stephan, Thanks for the update.
So is support for “running checkpoints with closed sources” part of FLIP-15 <https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=66853132>, or something separate? Regards, — Ken > On Mar 1, 2018, at 9:07 AM, Stephan Ewen <se...@apache.org> wrote: > > @Ken The issue you are running into is that Checkpointing works currently > only until the job reaches the point where the pipeline starts to drain out, > meaning when the sources are done. In your case, the source is done > immediately, sending out only one tuple. > > Running checkpoints with closed sources is something that's on the feature > list and will come soon… -------------------------------------------- http://about.me/kkrugler +1 530-210-6378
