You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/07/01 16:45:06 UTC
flink git commit: [FLINK-5893] [RM] Fix the bug of race condition for
removing previous JobManagerRegistration in ResourceManager
Repository: flink
Updated Branches:
refs/heads/master 6e3f839ac -> 750325e74
[FLINK-5893] [RM] Fix the bug of race condition for removing previous JobManagerRegistration in ResourceManager
This closes #3399.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/750325e7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/750325e7
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/750325e7
Branch: refs/heads/master
Commit: 750325e74c1cd91006b251f18f3ed8acf90c2a91
Parents: 6e3f839
Author: 淘江 <ta...@alibaba-inc.com>
Authored: Thu Feb 23 17:30:24 2017 +0800
Committer: Till Rohrmann <tr...@apache.org>
Committed: Sat Jul 1 17:33:29 2017 +0200
----------------------------------------------------------------------
.../apache/flink/runtime/resourcemanager/ResourceManager.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/750325e7/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
index 6e7c6af..dac053a 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
@@ -930,7 +930,12 @@ public abstract class ResourceManager<WorkerType extends Serializable>
@Override
public void jobLeaderLostLeadership(final JobID jobId, final UUID oldJobLeaderId) {
- ResourceManager.this.jobLeaderLostLeadership(jobId, oldJobLeaderId);
+ runAsync(new Runnable() {
+ @Override
+ public void run() {
+ ResourceManager.this.jobLeaderLostLeadership(jobId, oldJobLeaderId);
+ }
+ });
}
@Override