You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 187 Next »

Job Information

A job, derived from JobInProgress, in general holds some basic information, including:

  • jobId: BSPJobID. The id of this job.
  • user: String. See BSPJobContext.getUser() wherein configures via conf.get("user.name")
  • jobFile: Path. job.xml. See BSPJobClient.submitJobInternal()
  • localJobFile: Path. A local copied jobFile.
  • localJarFile: Path. A local copied jar file.
  • jobName: String. The name of this job.
  • status: JobStatus. Mainly JobStatus.State
  • superstepCount: long. This job's superstep count.
  • startTime: long. The time this job is started.
  • finishTime: long. The time this job is finished.
  • numBSPTasks: The number of BSP tasks to be launched.
  • Tasks: Actual launched TaskInProgresses depends on numBSPTasks.

TODO: An object that holds multiple tasks execution including successful/ failed/ current task

See Job Task Relation section

    • task id: TaskID object.
    • startTime: System.currentTimeMillis()
    • partition: The _i_th numBSPTasks
    • RawSplit: The _i_th RawSplit if RawSplit not null
    • SuccessfulTaskId: Set when TaskInProgress.completed() is called. TODO: isSuccessful
    • firstTaskId: The first task id.
    • currentTaskId:
    • MaxTaskAttempts: (constant) 4
    • MAX_TASK_EXEC: 1 TODO: what is this?
    • TaskStatus:
      • Phase: Denote at which phase current task is. See Task Phase below.
      • State: Denote the current state the task is. See Task State below.

Job Status

A job status contains:

  • PREP: This status is started when a job is created until all tasks are dispatched to groom servers.
  • RUNNING: When tasks are executed in GroomServers.
  • SUCCEEDED: When all tasks are in the SUCCEEDED state.
  • FAILED: When one or more tasks exceed its max attempt
  • KILLED: User/ Admin issues a kill command.

Task Phase

A single task phase.

  • STARTING: Initial phase
  • COMPUTE: Within bsp()
  • BARRIER_SYNC: Reaching sync().
  • CLEANUP: Finish entire supersteps execution.

Task State

This only indicate a task state.

  • UNASSIGNED: Initial state of a task.
  • RUNNING: Only valid when a task is either in COMPUTE or in BARRIER_SYNC phase.
  • SUCCEEDED: A task completes its execution at the end of CLEANUP phase.
  • FAILED: An exception or an error occurrs.
  • KILLED

Job Task Relation

  • No labels