本文整理了Java中org.apache.hadoop.mapred.Task.getPhase()
方法的一些代码示例,展示了Task.getPhase()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.getPhase()
方法的具体详情如下:
包路径:org.apache.hadoop.mapred.Task
类名称:Task
方法名:getPhase
[英]Return current phase of the task. needs to be synchronized as communication thread sends the phase every second
[中]返回任务的当前阶段。需要同步,因为通信线程每秒发送一次相位
代码示例来源:origin: com.facebook.hadoop/hadoop-core
/**
* Finish the tip.
*/
public void finishTip() {
LOG.info("Finishing TIP " + tip.getTask().getTaskID() +
" with status " +
tip.getStatus() + " and isTaskCleanupTask is : " +
tip.getTask().isTaskCleanupTask() + " and phase is " +
tip.getTask().getPhase() + " and finish time " +
timeToFinish + " at " +
System.currentTimeMillis());
try {
umbilicalProtocol.done(tip.getTask().getTaskID());
taskTracker.cleanupUmbilical(umbilicalProtocol);
} catch (IOException e) {
// This shouldn't happen as done does not really throw an IOE
LOG.fatal("Error while trying to call done on " +
tip.getTask().getTaskID(), e);
System.exit(-1);
}
tip.reportTaskFinished(false);
LOG.debug("After finishing, " + tip.getTask().getTaskID() + " has status " +
tip.getStatus() + " and isTaskCleanupTask is : " +
tip.getTask().isTaskCleanupTask() + " and phase is " +
tip.getTask().getPhase());
}
}
代码示例来源:origin: com.facebook.hadoop/hadoop-core
JvmMetrics.init(task.getPhase().toString(), job.getSessionId());
代码示例来源:origin: org.jvnet.hudson.hadoop/hadoop-core
JvmMetrics.init(task.getPhase().toString(), job.getSessionId());
代码示例来源:origin: org.apache.hadoop/hadoop-mapred
JvmMetrics.init(task.getPhase().toString(), job.getSessionId());
LOG.debug("Creating remote user to execute task: " + job.get("user.name"));
childUGI = UserGroupInformation.createRemoteUser(job.get("user.name"));
内容来源于网络,如有侵权,请联系作者删除!