[FLINK-5999] [resMgnr] Move JobLeaderIdService shut down into ResourceManagerRunner
The JobLeaderIdService is being created by the ResourceManagerRunner and then given to a ResourceManager. Before the ResourceManager stopped the service before being stopped itself. This could lead to a concurrent modification exception by a state changing action executed by the actor thread. In order to avoid this concurrent modification, the service's shut down is now being executed after the ResourceManager has been shut down. This closes #3526.
Showing
想要评论请 注册 或 登录