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 abd35fc86df8a11121c71391a6fd135202061590..bb74bdb56a9e80b930c2488668437d1b4669624c 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());