[FLINK-6269] Make UserCodeClassLoader final This closes #3682.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2cb60043 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2cb60043 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2cb60043 Branch: refs/heads/table-retraction Commit: 2cb60043d8fce4a291fbefeddce6598b442b8f01 Parents: b3ac693 Author: zcb <zhengcan...@huawei.com> Authored: Thu Apr 6 15:31:46 2017 +0800 Committer: zentol <ches...@apache.org> Committed: Thu Apr 6 19:35:50 2017 +0200 ---------------------------------------------------------------------- .../scala/org/apache/flink/runtime/jobmanager/JobManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/2cb60043/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala index 1e6d8d3..f2ecde5 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala @@ -1250,7 +1250,7 @@ class JobManager( "Cannot set up the user code libraries: " + t.getMessage, t) } - var userCodeLoader = libraryCacheManager.getClassLoader(jobGraph.getJobID) + val userCodeLoader = libraryCacheManager.getClassLoader(jobGraph.getJobID) if (userCodeLoader == null) { throw new JobSubmissionException(jobId, "The user code class loader could not be initialized.")
