Github user tnachen commented on a diff in the pull request:
https://github.com/apache/spark/pull/21027#discussion_r208468697
--- Diff:
resource-managers/mesos/src/main/scala/org/apache/spark/deploy/rest/mesos/MesosRestServer.scala
---
@@ -50,6 +50,24 @@ private[spark] class MesosRestServer(
new MesosKillRequestServlet(scheduler, masterConf)
protected override val statusRequestServlet =
new MesosStatusRequestServlet(scheduler, masterConf)
+
+ override def isServerHealthy(): Boolean =
!scheduler.isSchedulerDriverStopped()
+
+ override def serverStatus(): ServerStatusResponse = {
+ val s = new ServerStatusResponse
+ s.schedulerDriverStopped = scheduler.isSchedulerDriverStopped()
+ s.queuedDrivers = scheduler.getQueuedDriversSize
+ s.launchedDrivers = scheduler.getLaunchedDriversSize
+ s.pendingRetryDrivers = scheduler.getPendingRetryDriversSize
+ s.success = true
+ s.message = "iamok"
--- End diff --
How about leaving this blank?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
