Skip to content

Commit b3f9b9d

Browse files
Updated comment based on feedback.
1 parent 0840a95 commit b3f9b9d

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

yarn/src/main/scala/org/apache/spark/scheduler/cluster/YarnClusterSchedulerBackend.scala

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,12 @@ private[spark] class YarnClusterSchedulerBackend(
9898
}
9999
}
100100

101-
// Build the HTTP address for the node and build the URL for the logs.
101+
// Now that we have found the report for the Node Manager that the AM is running on, we
102+
// can get the base HTTP address for the Node manager from the report.
103+
// The format used for the logs for each container is well-known and can be constructed
104+
// using the NM's HTTP address and the container ID.
105+
// The NM may be running several containers, but we can build the URL for the AM using
106+
// the AM's container ID, which we already know.
102107
nodeReport.foreach { report =>
103108
val httpAddress = report.getHttpAddress
104109
// lookup appropriate http scheme for container log urls

0 commit comments

Comments
 (0)