File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed
yarn/src/main/scala/org/apache/spark/scheduler/cluster Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments