Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Invalid
-
3.0.0
-
None
-
None
Description
Current memory composition `amMemory` + `amMemoryOverhead`
val capability = Records.newRecord(classOf[Resource]) capability.setMemory(amMemory + amMemoryOverhead) capability.setVirtualCores(amCores) if (amResources.nonEmpty) { ResourceRequestHelper.setResourceRequests(amResources, capability) } logDebug(s"Created resource capability for AM request: $capability")
// Add Xmx for AM memory javaOpts += "-Xmx" + amMemory + "m"
It is possible that the physical memory of the container exceeds the limit and is killed by yarn.
I suggest setting `-XX:MaxDirectMemorySize` here
// Add Xmx for AM memory javaOpts += "-Xmx" + amMemory + "m" javaOpts += s"-XX:MaxDirectMemorySize=${amMemoryOverhead}m"
Attachments
Issue Links
- links to