Skip to content

Commit 1071f40

Browse files
committed
make java return values immutable
1 parent 2d754f7 commit 1071f40

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

core/src/main/scala/org/apache/spark/resource/ExecutorResourceRequests.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ private[spark] class ExecutorResourceRequests() extends Serializable {
3939

4040
def requests: Map[String, ExecutorResourceRequest] = _executorResources.asScala.toMap
4141

42-
def requestsJMap: JMap[String, ExecutorResourceRequest] = _executorResources.asScala.asJava
42+
def requestsJMap: JMap[String, ExecutorResourceRequest] = _executorResources.asScala.toMap.asJava
4343

4444
/**
4545
* Specify heap memory. The value specified will be converted to MiB.

core/src/main/scala/org/apache/spark/resource/TaskResourceRequests.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ private[spark] class TaskResourceRequests() extends Serializable {
3838

3939
def requests: Map[String, TaskResourceRequest] = _taskResources.asScala.toMap
4040

41-
def requestsJMap: JMap[String, TaskResourceRequest] = _taskResources.asScala.asJava
41+
def requestsJMap: JMap[String, TaskResourceRequest] = _taskResources.asScala.toMap.asJava
4242

4343
/**
4444
* Specify number of cpus per Task.

0 commit comments

Comments
 (0)