GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3526
[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.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tillrohrmann/flink
resourceManagerServiceLifecycle
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3526.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3526
----
commit 978ad4d55c0b52931c00d994c676dfd1d57b45b0
Author: Till Rohrmann <[email protected]>
Date: 2017-03-13T14:55:02Z
[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.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
