Hi Luan,
this sound more of a new feature request to me. Maybe you can already
open an issue for it.
I will loop in Chesnay in CC if there is some possibility to achieve
this already?
Regards,
Timo
On 21.09.20 06:37, Luan Cooper wrote:
Hi
We're running flink standalone cluster on k8s
when deleting a taskmanager pod manually, jobmanager *should disconnect
it immediately*
however no such rest api available right now
we have to wait `akka.tcp.timeout` which means 30s later or more
What if I want to disconnect tm via rest api
Which way did you suggest ?
1. add disconnectTaskManager to
org.apache.flink.runtime.dispatcher.Dispatcher
which means a new Interface
CompletableFuture<Acknowledge>disconnectTaskManager(JobID jobId, ResourceID
resourceId);
in org.apache.flink.runtime.webmonitor.RestfulGateway
2. Any other suggestions?
Thanks
