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!