Re: Stopping flink application with /jobs/:jobid/savepoints or /jobs/:jobid/stop

uit.com>; Benenson, Mikhail ; > LeVeck, Matt ; Kathula, Sandeep < > sandeep_kath...@intuit.com> > *Subject:* Re: Stopping flink application with /jobs/:jobid/savepoints or > /jobs/:jobid/stop > > This email is from an external sender. > > > Hi Omkar, > > For t

Re: Stopping flink application with /jobs/:jobid/savepoints or /jobs/:jobid/stop

From: Kostas Kloudas Sent: Tuesday, June 9, 2020 4:48 AM To: Deshpande, Omkar Cc: user@flink.apache.org ; Hwang, Nick ; Benenson, Mikhail ; LeVeck, Matt ; Kathula, Sandeep Subject: Re: Stopping flink application with /jobs/:jobid/savepoints or /jobs/:jobid/stop This email is from an externa

Re: Stopping flink application with /jobs/:jobid/savepoints or /jobs/:jobid/stop

Hi Omkar, For the first part of the question where you set the "drain" to false and the state gets drained, this can be an issue on our side. Just to clarify, no matter what is the value of the "drain", Flink always takes a savepoint. Drain simply means that we also send MAX_WATERMARK before takin

Stopping flink application with /jobs/:jobid/savepoints or /jobs/:jobid/stop

Hello, When I try to stop the job with /jobs/:jobid/stop REST endpoint, the state gets drained, even if I pass {"drain":false} in the body of the post request. Is the value of drain flag true b