这是一个典型main
的 Hadoop Job 方法:
public class MyHadoopJobDriver extends Configured implements Tool {
public static void main(String[] args) throws Exception {
int exitCode = ToolRunner.run(new MyHadoopJobDriver(), args);
System.exit(exitCode);
}
...
}
当我运行这个作业hadoop MyHadoopJobDriver
时,上面的代码是在任务跟踪器上自己的 JVM 中执行的吗?那么一旦作业被调度,地图任务就会被分配给任务跟踪器?