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

Reply via email to