From 084bb4f8e392a14e47c356037400273322232257 Mon Sep 17 00:00:00 2001
From: zjureel <zjureel@gmail.com>
Date: Mon, 26 Jun 2017 18:18:18 +0800
Subject: [PATCH] [FLINK-6310] Use correct lock for synchronization in
 LocalExecutor

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

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 abd35fc86df..bb74bdb56a9 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());
-- 
GitLab