diff options
| -rw-r--r-- | core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala | 22 |
1 files changed, 16 insertions, 6 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala b/core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala index 3fb860582c..ebbbbd3b71 100644 --- a/core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala +++ b/core/src/main/scala/org/apache/spark/deploy/master/ui/MasterPage.scala @@ -176,8 +176,15 @@ private[ui] class MasterPage(parent: MasterWebUI) extends WebUIPage("") { private def workerRow(worker: WorkerInfo): Seq[Node] = { <tr> <td> - <a href={UIUtils.makeHref(parent.master.reverseProxy, - worker.id, worker.webUiAddress)}>{worker.id}</a> + { + if (worker.isAlive()) { + <a href={UIUtils.makeHref(parent.master.reverseProxy, worker.id, worker.webUiAddress)}> + {worker.id} + </a> + } else { + worker.id + } + } </td> <td>{worker.host}:{worker.port}</td> <td>{worker.state}</td> @@ -247,10 +254,13 @@ private[ui] class MasterPage(parent: MasterWebUI) extends WebUIPage("") { <td>{driver.id} {killLink}</td> <td>{driver.submitDate}</td> <td>{driver.worker.map(w => - <a href= - {UIUtils.makeHref(parent.master.reverseProxy, w.id, w.webUiAddress)}> - {w.id.toString}</a> - ).getOrElse("None")} + if (w.isAlive()) { + <a href={UIUtils.makeHref(parent.master.reverseProxy, w.id, w.webUiAddress)}> + {w.id.toString} + </a> + } else { + w.id.toString + }).getOrElse("None")} </td> <td>{driver.state}</td> <td sorttable_customkey={driver.desc.cores.toString}> |