make java return values immutable

apache · Apr 2, 2020 · 1071f40 · 1071f40
1 parent 2d754f7
commit 1071f40
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/resource/ExecutorResourceRequests.scala b/core/src/main/scala/org/apache/spark/resource/ExecutorResourceRequests.scala
@@ -39,7 +39,7 @@ private[spark] class ExecutorResourceRequests() extends Serializable {
 
   def requests: Map[String, ExecutorResourceRequest] = _executorResources.asScala.toMap
 
-  def requestsJMap: JMap[String, ExecutorResourceRequest] = _executorResources.asScala.asJava
+  def requestsJMap: JMap[String, ExecutorResourceRequest] = _executorResources.asScala.toMap.asJava
 
   /**
    * Specify heap memory. The value specified will be converted to MiB.

diff --git a/core/src/main/scala/org/apache/spark/resource/TaskResourceRequests.scala b/core/src/main/scala/org/apache/spark/resource/TaskResourceRequests.scala
@@ -38,7 +38,7 @@ private[spark] class TaskResourceRequests() extends Serializable {
 
   def requests: Map[String, TaskResourceRequest] = _taskResources.asScala.toMap
 
-  def requestsJMap: JMap[String, TaskResourceRequest] = _taskResources.asScala.asJava
+  def requestsJMap: JMap[String, TaskResourceRequest] = _taskResources.asScala.toMap.asJava
 
   /**
    * Specify number of cpus per Task.