Re: [DISCUSS] Graceful Shutdown Handling by UDFs.

2019-07-08 Thread Kostas Kloudas
Hi Konstantin, Yes you are right that `cancel` falls under the "abrupt" termination of a job. I will update the FLIP accordingly. Cheers, Kostas On Sun, Jul 7, 2019 at 11:38 AM Konstantin Knauf wrote: > Hi Klou, > > +1 for this proposal. I am missing any mention of "cancel" in the design > doc

Re: [DISCUSS] Graceful Shutdown Handling by UDFs.

2019-07-07 Thread Konstantin Knauf
Hi Klou, +1 for this proposal. I am missing any mention of "cancel" in the design document though. In my understanding we are not planning to deprecate "cancel" completely (just cancel-with-savepoint, which is superseded by "stop"). In any case we should consider it in the design document. It seem

[DISCUSS] Graceful Shutdown Handling by UDFs.

2019-07-04 Thread Kostas Kloudas
Hi all, In many cases, UDFs (User Defined Functions) need to be able to perform application-specific actions when they stop in an orderly manner. Currently, Flink's UDFs, and more specifically the RichFunction which exposes lifecycle-related hooks, only have a close() method which is called in any