flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: [FLINK-6310] Use correct lock for synchronization in LocalExecutor
Date Mon, 03 Jul 2017 09:49:38 GMT
Repository: flink
Updated Branches:
  refs/heads/master 750325e74 -> 084bb4f8e


[FLINK-6310] Use correct lock for synchronization in LocalExecutor


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/084bb4f8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/084bb4f8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/084bb4f8

Branch: refs/heads/master
Commit: 084bb4f8e392a14e47c356037400273322232257
Parents: 750325e
Author: zjureel <zjureel@gmail.com>
Authored: Mon Jun 26 18:18:18 2017 +0800
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Mon Jul 3 11:48:21 2017 +0200

----------------------------------------------------------------------
 .../src/main/java/org/apache/flink/client/LocalExecutor.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/084bb4f8/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java
----------------------------------------------------------------------
diff --git a/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java b/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java
index abd35fc..bb74bdb 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/LocalExecutor.java
@@ -220,7 +220,7 @@ public class LocalExecutor extends PlanExecutor {
 
 	@Override
 	public void endSession(JobID jobID) throws Exception {
-		synchronized (LocalExecutor.class) {
+		synchronized (this.lock) {
 			LocalFlinkMiniCluster flink = this.flink;
 			if (flink != null) {
 				ActorGateway leaderGateway = flink.getLeaderGateway(AkkaUtils.getDefaultTimeoutAsFiniteDuration());


Mime
View raw message