#49 add request_cores to master json

Kyligence · May 14, 2020 · f076165 · f076165
1 parent 30183d4
commit f076165
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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) ~