org.apache.hadoop.mapred.jobcontrol.Job.getMessage()方法的使用及代码示例

x33g5p2x  于2022-01-22 转载在 其他  
字(1.4k)|赞(0)|评价(0)|浏览(114)

本文整理了Java中org.apache.hadoop.mapred.jobcontrol.Job.getMessage()方法的一些代码示例,展示了Job.getMessage()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Job.getMessage()方法的具体详情如下:
包路径:org.apache.hadoop.mapred.jobcontrol.Job
类名称:Job
方法名:getMessage

Job.getMessage介绍

暂无

代码示例

代码示例来源:origin: org.jvnet.hudson.hadoop/hadoop-core

this.state = Job.DEPENDENT_FAILED;
this.message = "depending job " + i + " with jobID "
 + pred.getJobID() + " failed. " + pred.getMessage();
break;

代码示例来源:origin: com.facebook.hadoop/hadoop-core

this.state = Job.DEPENDENT_FAILED;
this.message = "depending job " + i + " with jobID "
 + pred.getJobID() + " failed. " + pred.getMessage();
break;

代码示例来源:origin: org.apache.pig/pig

/**
 * Updates the statistics after a patch of jobs is done
 *
 * @param jc the job control
 */
public static void accumulateStats(JobControl jc) {
  SimplePigStats ps = (SimplePigStats)PigStats.get();
  MRScriptState ss = MRScriptState.get();
  for (Job job : jc.getSuccessfulJobs()) {
    MRJobStats js = addSuccessJobStats(ps, job);
    if (js != null) {
      ss.emitjobFinishedNotification(js);
    }
  }
  for (Job job : jc.getFailedJobs()) {
    MRJobStats js = addFailedJobStats(ps, job);
    if (js != null) {
      js.setErrorMsg(job.getMessage());
      ss.emitJobFailedNotification(js);
    }
  }
}

代码示例来源:origin: org.apache.pig/pig

private void getStats(Job job, boolean errNotDbg,
    PigContext pigContext) throws ExecException {
  JobID MRJobID = job.getAssignedJobID();
  String jobMessage = job.getMessage();
  Exception backendException = null;
  if (MRJobID == null) {

相关文章