File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
alpha/src/main/scala/org/apache/spark/deploy/yarn
stable/src/main/scala/org/apache/spark/deploy/yarn Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -47,7 +47,7 @@ private[yarn] class YarnAllocationHandler(
4747 private val lastResponseId = new AtomicInteger ()
4848 private val releaseList : CopyOnWriteArrayList [ContainerId ] = new CopyOnWriteArrayList ()
4949
50- override protected def allocateContainers (count : Int ) = {
50+ override protected def allocateContainers (count : Int ): YarnAllocateResponse = {
5151 var resourceRequests : List [ResourceRequest ] = null
5252
5353 // default.
@@ -217,7 +217,7 @@ private[yarn] class YarnAllocationHandler(
217217 retval
218218 }
219219
220- class AlphaAllocateResponse (response : AMResponse ) extends YarnAllocateResponse {
220+ private class AlphaAllocateResponse (response : AMResponse ) extends YarnAllocateResponse {
221221 override def getAllocatedContainers () = response.getAllocatedContainers()
222222 override def getAvailableResources () = response.getAvailableResources()
223223 override def getCompletedContainersStatuses () = response.getCompletedContainersStatuses()
Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ private[yarn] class YarnAllocationHandler(
4646 amClient.releaseAssignedContainer(container.getId())
4747 }
4848
49- override protected def allocateContainers (count : Int ) = {
49+ override protected def allocateContainers (count : Int ): YarnAllocateResponse = {
5050 addResourceRequests(count)
5151
5252 // We have already set the container request. Poll the ResourceManager for a response.
@@ -200,7 +200,7 @@ private[yarn] class YarnAllocationHandler(
200200 requests
201201 }
202202
203- class StableAllocateResponse (response : AllocateResponse ) extends YarnAllocateResponse {
203+ private class StableAllocateResponse (response : AllocateResponse ) extends YarnAllocateResponse {
204204 override def getAllocatedContainers () = response.getAllocatedContainers()
205205 override def getAvailableResources () = response.getAvailableResources()
206206 override def getCompletedContainersStatuses () = response.getCompletedContainersStatuses()
You can’t perform that action at this time.
0 commit comments