Package org.apache.hadoop.mapred

Class JobStatus

java.lang.Object
org.apache.hadoop.mapreduce.JobStatus
org.apache.hadoop.mapred.JobStatus
All Implemented Interfaces:
Cloneable, Writable
@Public @Stable public class JobStatus extends JobStatus
Describes the current status of a job. This is not intended to be a comprehensive piece of data. For that, look at JobProfile.

  • Field Details

    • RUNNING

      public static final int RUNNING

    • SUCCEEDED

      public static final int SUCCEEDED

    • FAILED

      public static final int FAILED

    • PREP

      public static final int PREP

    • KILLED

      public static final int KILLED

  • Constructor Details

    • JobStatus

      public JobStatus()

    • JobStatus

      @Deprecated public JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState)
      Deprecated.

    • JobStatus

      @Deprecated public JobStatus(JobID jobid, float mapProgress, float reduceProgress, int runState)
      Deprecated.
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      runState - The current state of the job

    • JobStatus

      @Deprecated public JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp)
      Deprecated.
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      runState - The current state of the job
      jp - Priority of the job.

    • JobStatus

      @Deprecated public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp)
      Deprecated.
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      setupProgress - The progress made on the setup
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      cleanupProgress - The progress made on the cleanup
      runState - The current state of the job
      jp - Priority of the job.

    • JobStatus

      public JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, String user, String jobName, String jobFile, String trackingUrl)
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      cleanupProgress - The progress made on cleanup
      runState - The current state of the job
      user - userid of the person who submitted the job.
      jobName - user-specified job name.
      jobFile - job configuration file.
      trackingUrl - link to the web-ui for details of the job.

    • JobStatus

      public JobStatus(JobID jobid, float mapProgress, float reduceProgress, int runState, String user, String jobName, String jobFile, String trackingUrl)
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      runState - The current state of the job
      user - userid of the person who submitted the job.
      jobName - user-specified job name.
      jobFile - job configuration file.
      trackingUrl - link to the web-ui for details of the job.

    • JobStatus

      public JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl)
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      runState - The current state of the job
      jp - Priority of the job.
      user - userid of the person who submitted the job.
      jobName - user-specified job name.
      jobFile - job configuration file.
      trackingUrl - link to the web-ui for details of the job.

    • JobStatus

      public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl)
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      setupProgress - The progress made on the setup
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      cleanupProgress - The progress made on the cleanup
      runState - The current state of the job
      jp - Priority of the job.
      user - userid of the person who submitted the job.
      jobName - user-specified job name.
      jobFile - job configuration file.
      trackingUrl - link to the web-ui for details of the job.

    • JobStatus

      public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl, boolean isUber)
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      setupProgress - The progress made on the setup
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      cleanupProgress - The progress made on the cleanup
      runState - The current state of the job
      jp - Priority of the job.
      user - userid of the person who submitted the job.
      jobName - user-specified job name.
      jobFile - job configuration file.
      trackingUrl - link to the web-ui for details of the job.
      isUber - Whether job running in uber mode

    • JobStatus

      public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl, boolean isUber, String historyFile)
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      setupProgress - The progress made on the setup
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      cleanupProgress - The progress made on the cleanup
      runState - The current state of the job
      jp - Priority of the job.
      user - userid of the person who submitted the job.
      jobName - user-specified job name.
      jobFile - job configuration file.
      trackingUrl - link to the web-ui for details of the job.
      isUber - Whether job running in uber mode
      historyFile - history file

    • JobStatus

      public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String queue, String jobFile, String trackingUrl)
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      setupProgress - The progress made on the setup
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      cleanupProgress - The progress made on the cleanup
      runState - The current state of the job
      jp - Priority of the job.
      user - userid of the person who submitted the job.
      jobName - user-specified job name.
      queue - job queue name.
      jobFile - job configuration file.
      trackingUrl - link to the web-ui for details of the job.

    • JobStatus

      public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String queue, String jobFile, String trackingUrl, boolean isUber)
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      setupProgress - The progress made on the setup
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      cleanupProgress - The progress made on the cleanup
      runState - The current state of the job
      jp - Priority of the job.
      user - userid of the person who submitted the job.
      jobName - user-specified job name.
      queue - job queue name.
      jobFile - job configuration file.
      trackingUrl - link to the web-ui for details of the job.
      isUber - Whether job running in uber mode

    • JobStatus

      public JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String queue, String jobFile, String trackingUrl, boolean isUber, String historyFile)
      Create a job status object for a given jobid.
      Parameters:
      jobid - The jobid of the job
      setupProgress - The progress made on the setup
      mapProgress - The progress made on the maps
      reduceProgress - The progress made on the reduces
      cleanupProgress - The progress made on the cleanup
      runState - The current state of the job
      jp - Priority of the job.
      user - userid of the person who submitted the job.
      jobName - user-specified job name.
      queue - job queue name.
      jobFile - job configuration file.
      trackingUrl - link to the web-ui for details of the job.
      isUber - Whether job running in uber mode
      historyFile - history file

  • Method Details

    • getJobRunState

      public static String getJobRunState(int state)
      Helper method to get human-readable state of the job.
      Parameters:
      state - job state
      Returns:
      human-readable state of the job

    • downgrade

      public static JobStatus downgrade(JobStatus stat)

    • getJobId

      @Deprecated public String getJobId()
      Deprecated.
      use getJobID instead

    • getJobID

      public JobID getJobID()
      Overrides:
      getJobID in class JobStatus
      Returns:
      The jobid of the Job

    • getJobPriority

      public JobPriority getJobPriority()
      Return the priority of the job
      Returns:
      job priority

    • setMapProgress

      protected void setMapProgress(float p)
      Sets the map progress of this job
      Overrides:
      setMapProgress in class JobStatus
      Parameters:
      p - The value of map progress to set to

    • setCleanupProgress

      protected void setCleanupProgress(float p)
      Sets the cleanup progress of this job
      Overrides:
      setCleanupProgress in class JobStatus
      Parameters:
      p - The value of cleanup progress to set to

    • setSetupProgress

      protected void setSetupProgress(float p)
      Sets the setup progress of this job
      Overrides:
      setSetupProgress in class JobStatus
      Parameters:
      p - The value of setup progress to set to

    • setReduceProgress

      protected void setReduceProgress(float p)
      Sets the reduce progress of this Job
      Overrides:
      setReduceProgress in class JobStatus
      Parameters:
      p - The value of reduce progress to set to

    • setFinishTime

      protected void setFinishTime(long finishTime)
      Set the finish time of the job
      Overrides:
      setFinishTime in class JobStatus
      Parameters:
      finishTime - The finishTime of the job

    • setHistoryFile

      protected void setHistoryFile(String historyFile)
      Set the job history file url for a completed job
      Overrides:
      setHistoryFile in class JobStatus

    • setTrackingUrl

      protected void setTrackingUrl(String trackingUrl)
      Set the link to the web-ui for details of the job.
      Overrides:
      setTrackingUrl in class JobStatus

    • setRetired

      protected void setRetired()
      Set the job retire flag to true.
      Overrides:
      setRetired in class JobStatus

    • setRunState

      @Private public void setRunState(int state)
      Change the current run state of the job. The setter is public to be compatible with M/R 1.x, however, it should be used internally.
      Parameters:
      state - the state of the job

    • getRunState

      public int getRunState()
      Returns:
      running state of the job

    • setStartTime

      protected void setStartTime(long startTime)
      Set the start time of the job
      Overrides:
      setStartTime in class JobStatus
      Parameters:
      startTime - The startTime of the job

    • setUsername

      protected void setUsername(String userName)
      Overrides:
      setUsername in class JobStatus
      Parameters:
      userName - The username of the job

    • setSchedulingInfo

      @Private public void setSchedulingInfo(String schedulingInfo)
      Used to set the scheduling information associated to a particular Job. The setter is public to be compatible with M/R 1.x, however, it should be used internally.
      Overrides:
      setSchedulingInfo in class JobStatus
      Parameters:
      schedulingInfo - Scheduling information of the job

    • setJobACLs

      protected void setJobACLs(Map<org.apache.hadoop.mapreduce.JobACL,AccessControlList> acls)
      Description copied from class: JobStatus
      Set the job acls.
      Overrides:
      setJobACLs in class JobStatus
      Parameters:
      acls - Map from JobACL to AccessControlList

    • setFailureInfo

      public void setFailureInfo(String failureInfo)
      Description copied from class: JobStatus
      Set diagnostic information.
      Overrides:
      setFailureInfo in class JobStatus
      Parameters:
      failureInfo - diagnostic information

    • setJobPriority

      public void setJobPriority(JobPriority jp)
      Set the priority of the job, defaulting to NORMAL.
      Parameters:
      jp - new job priority

    • mapProgress

      public float mapProgress()
      Returns:
      Percentage of progress in maps

    • cleanupProgress

      public float cleanupProgress()
      Returns:
      Percentage of progress in cleanup

    • setupProgress

      public float setupProgress()
      Returns:
      Percentage of progress in setup

    • reduceProgress

      public float reduceProgress()
      Returns:
      Percentage of progress in reduce