diff --git a/src/main/java/org/apache/hadoop/mapred/JobConf.java b/src/main/java/org/apache/hadoop/mapred/JobConf.java index 03f1160..7754ca6 100644 --- a/src/main/java/org/apache/hadoop/mapred/JobConf.java +++ b/src/main/java/org/apache/hadoop/mapred/JobConf.java @@ -1430,6 +1430,15 @@ public class JobConf extends Configuration { } /** + * Get the user-specified job description. This is only used to identify the + * job to the user. + * + * @return the job's description, defaulting to "". + */ + public String getJobDescription() { + return get(JobContext.JOB_DESCRIPTION, ""); + } + /** * Set the user-specified job name. * * @param name the job's new name. @@ -1437,7 +1446,14 @@ public class JobConf extends Configuration { public void setJobName(String name) { set(JobContext.JOB_NAME, name); } - + /** + * Set the user-specified job description. + * + * @param name the job's new description. + */ + public void setJobDescription(String description) { + set(JobContext.JOB_DESCRIPTION, description); + } /** * Get the user-specified session identifier. The default is the empty string. * diff --git a/src/main/java/org/apache/hadoop/mapreduce/Job.java b/src/main/java/org/apache/hadoop/mapreduce/Job.java index cfc3437..c627903 100644 --- a/src/main/java/org/apache/hadoop/mapreduce/Job.java +++ b/src/main/java/org/apache/hadoop/mapreduce/Job.java @@ -1014,6 +1014,16 @@ public class Job extends JobContextImpl implements JobContext { } /** + * Set the user-specified job description. + * + * @param description the job's new description. + * @throws IllegalStateException if the job is submitted + */ + public void setJobDescription(String description) throws IllegalStateException { + ensureState(JobState.DEFINE); + conf.setJobDescription(description); + } + /** * Turn speculative execution on or off for this job. * * @param speculativeExecution true if speculative execution diff --git a/src/main/java/org/apache/hadoop/mapreduce/MRJobConfig.java b/src/main/java/org/apache/hadoop/mapreduce/MRJobConfig.java index e09463a..ce93391 100644 --- a/src/main/java/org/apache/hadoop/mapreduce/MRJobConfig.java +++ b/src/main/java/org/apache/hadoop/mapreduce/MRJobConfig.java @@ -54,6 +54,8 @@ public interface MRJobConfig { public static final String ID = "mapreduce.job.id"; public static final String JOB_NAME = "mapreduce.job.name"; + + public static final String JOB_DESCRIPTION = "mapreduce.job.description"; public static final String JAR_UNPACK_PATTERN = "mapreduce.job.jar.unpack.pattern";