From f076165d04454ccb4725ce70596a068f2b2f59c4 Mon Sep 17 00:00:00 2001 From: ZhansShaoxiong Date: Tue, 14 Apr 2020 18:24:03 +0800 Subject: [PATCH] #49 add request_cores to master json --- core/src/main/scala/org/apache/spark/deploy/JsonProtocol.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/org/apache/spark/deploy/JsonProtocol.scala b/core/src/main/scala/org/apache/spark/deploy/JsonProtocol.scala index 7212696166570..acd1612d9ed97 100644 --- a/core/src/main/scala/org/apache/spark/deploy/JsonProtocol.scala +++ b/core/src/main/scala/org/apache/spark/deploy/JsonProtocol.scala @@ -80,6 +80,7 @@ private[deploy] object JsonProtocol { ("starttime" -> obj.startTime) ~ ("name" -> obj.desc.name) ~ ("cores" -> obj.coresGranted) ~ + ("request_cores" -> obj.desc.maxCores.getOrElse(0)) ~ ("user" -> obj.desc.user) ~ ("memoryperslave" -> obj.desc.memoryPerExecutorMB) ~ ("submitdate" -> obj.submitDate.toString) ~