I see that this is an important issue. Will try to review this soon. Till and me are the only ones that worked in this, and unfortunately is out this week and the next, and I am travelling a lot, being a bit swamped with conferences. Will try to get to that asap...
On Wed, Apr 18, 2018 at 12:43 AM, Eron Wright <eronwri...@gmail.com> wrote: > Hello, > > We see an issue with the use of `MasterTriggerRestoreHook` to synchronize > the state of a source function with that of an external system. I'd like > the fix to be considered for 1.5. > > There's a patch ready: > https://github.com/apache/flink/pull/5427 > > Thanks! >