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 <[email protected]> Authored: Sun Apr 1 17:14:50 2018 +0800 Committer: Dawid Wysakowicz <[email protected]> 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
