add comment

Ngone51 · Ngone51 · commit d2468407f3d0 · 2020-09-07T21:30:16.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala b/core/src/main/scala/org/apache/spark/deploy/DeployMessage.scala
@@ -187,6 +187,8 @@ private[deploy] object DeployMessages {
     Utils.checkHostPort(hostPort)
   }
 
+  // When the host of Worker is lost or decommissioned, the `workerHost` is the host address
+  // of that Worker. Otherwise, it's None.
   case class ExecutorUpdated(id: Int, state: ExecutorState, message: Option[String],
     exitStatus: Option[Int], workerHost: Option[String])
 

Original file line number	Diff line number	Diff line change
`@@ -187,6 +187,8 @@ private[deploy] object DeployMessages {`
`187`	`187`	`Utils.checkHostPort(hostPort)`
`188`	`188`	`}`
`189`	`189`
	`190`	+ // When the host of Worker is lost or decommissioned, the `workerHost` is the host address
	`191`	`+ // of that Worker. Otherwise, it's None.`
`190`	`192`	`case class ExecutorUpdated(id: Int, state: ExecutorState, message: Option[String],`
`191`	`193`	`exitStatus: Option[Int], workerHost: Option[String])`
`192`	`194`