提交 084bb4f8 编写于 作者: Z zjureel 提交者: Aljoscha Krettek

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

上级 750325e7
...@@ -220,7 +220,7 @@ public class LocalExecutor extends PlanExecutor { ...@@ -220,7 +220,7 @@ public class LocalExecutor extends PlanExecutor {
@Override @Override
public void endSession(JobID jobID) throws Exception { public void endSession(JobID jobID) throws Exception {
synchronized (LocalExecutor.class) { synchronized (this.lock) {
LocalFlinkMiniCluster flink = this.flink; LocalFlinkMiniCluster flink = this.flink;
if (flink != null) { if (flink != null) {
ActorGateway leaderGateway = flink.getLeaderGateway(AkkaUtils.getDefaultTimeoutAsFiniteDuration()); ActorGateway leaderGateway = flink.getLeaderGateway(AkkaUtils.getDefaultTimeoutAsFiniteDuration());
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册