You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2018/06/05 12:57:24 UTC
flink git commit: [FLINK-7917] The return of taskInformationOrBlobKey
should be placed inside synchronized in ExecutionJobVertex
Repository: flink
Updated Branches:
refs/heads/master a0f4239fa -> e455285b6
[FLINK-7917] The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex
This closes #5798
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e455285b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e455285b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e455285b
Branch: refs/heads/master
Commit: e455285b68a441ce69160e43faba9f98e1a192ad
Parents: a0f4239
Author: yanghua <ya...@gmail.com>
Authored: Sun Apr 1 17:14:50 2018 +0800
Committer: Dawid Wysakowicz <dw...@apache.org>
Committed: Tue Jun 5 14:55:40 2018 +0200
----------------------------------------------------------------------
.../apache/flink/runtime/executiongraph/ExecutionJobVertex.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/e455285b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
index e5b7aa5..0691cc7 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java
@@ -395,9 +395,9 @@ public class ExecutionJobVertex implements AccessExecutionJobVertex, Archiveable
getJobId(),
blobWriter);
}
- }
- return taskInformationOrBlobKey;
+ return taskInformationOrBlobKey;
+ }
}
@Override