diff --git a/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala b/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala index c3b7cc0d7d331..57af76b46fe64 100644 --- a/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala +++ b/resource-managers/yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnAllocator.scala @@ -317,7 +317,7 @@ private[yarn] class YarnAllocator( customSparkResources } val resource = - Resource.newInstance(resourcesWithDefaults.totalMemMiB, resourcesWithDefaults.cores) + Resource.newInstance(resourcesWithDefaults.totalMemMiB.toInt, resourcesWithDefaults.cores) ResourceRequestHelper.setResourceRequests(customResources, resource) logDebug(s"Created resource capability: $resource") rpIdToYarnResource.putIfAbsent(rp.id, resource)