官术网_书友最值得收藏!

Jobs

Jobs is the default tab of Spark UI. It shows the status of all the applications executed within a SparkContext. It can be accessed at http://localhost:4040/jobs/.

It consists of three sections:

  • Active Jobs: This section is for the jobs that are currently running
  • Completed Jobs: This section is for the jobs that successfully completed
  • Failed Jobs: This section is for the jobs that were failed

It is shown in the following screenshot:

Sections of Spark UI are created lazily and can be visible if required. For example, the Active Jobs section will only be visible if there is a job that is currently running. Similarly, the Failed Jobs and Completed Jobs sections are visible only if there is a job that failed or successfully completed.

The Jobs tab section of Spark UI is rendered using the org.apache.spark.ui.jobs.JobsTab class that uses org.apache.spark.ui.jobs.JobProgressListener to get the statistics of the job.

After executing all the jobs mentioned in the Spark REPL also known as CLI section, Spark UI will look as follows:

Also, if you expand the Event Timeline section, you can see the time at which SparkContext started (that is, driver was initiated) and the jobs were executed along with their status:

Also, by clicking on any of the jobs, you can see the details of the job, that is, the Event Timeline of the job and the DAG of the transformations and stages executed during the execution of the job, as follows:

主站蜘蛛池模板: 温泉县| 襄樊市| 安阳县| 恩施市| 五河县| 鄯善县| 万全县| 郸城县| 安岳县| 娄烦县| 舞阳县| 炉霍县| 左贡县| 阜康市| 富民县| 黄平县| 隆德县| 尖扎县| 日土县| 都江堰市| 怀化市| 淳安县| 大庆市| 托里县| 林州市| 故城县| 德格县| 西乌珠穆沁旗| 临高县| 巴中市| 阳城县| 防城港市| 林口县| 广元市| 宁安市| 赣州市| 沂源县| 舟曲县| 兴化市| 县级市| 栾川县|