You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Yun Zhao (JIRA)" <ji...@apache.org> on 2015/08/21 09:03:45 UTC

[jira] [Created] (SPARK-10149) Locality Level is ANY on "Details for Stage" WebUI page

Yun Zhao created SPARK-10149:
--------------------------------

             Summary: Locality Level is ANY on "Details for Stage" WebUI page
                 Key: SPARK-10149
                 URL: https://issues.apache.org/jira/browse/SPARK-10149
             Project: Spark
          Issue Type: Bug
          Components: Spark Core, Web UI
    Affects Versions: 1.4.1
            Reporter: Yun Zhao


Locality Level is ANY on "Details for Stage" WebUI page


When a sc.textFile(XX) program is running, Locality Level is ANY which should be NODE_LOCAL on stage 0. 


org.apache.spark.scheduler.TaskSetManager

      // Check for node-local tasks
      if (TaskLocality.isAllowed(locality, TaskLocality.NODE_LOCAL)) {
        for (index <- speculatableTasks if canRunOnHost(index)) {
          val locations = tasks(index).preferredLocations.map(_.host)
          if (locations.contains(host)) {
            speculatableTasks -= index
            return Some((index, TaskLocality.NODE_LOCAL))
          }
        }
      }
	  

The variable "locations" is hostname of HDFS split, which is from InetAddress.getHostName.
The variable "host" is ip of Executor, which is from InetAddress.getLocalHost.getHostAddress.


org.apache.spark.deploy.worker.WorkerArguments
var host = Utils.localHostName()



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org