From 03dd6b53ee08b1843019a2faf37b420fb8b27a3e Mon Sep 17 00:00:00 2001 From: zcb Date: Thu, 6 Apr 2017 15:31:46 +0800 Subject: [PATCH] var could be val --- .../scala/org/apache/flink/runtime/jobmanager/JobManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 9d53aa28ff4f1..a49986d3a7d8d 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 @@ -1242,7 +1242,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.")