Yarn

指定向 hive 对象提交任务

1
2
[xiamu@hadoop202 hadoop-3.1.3]$ hadoop jar share/hadoop/mapreduce/hadoop-mapreduce-examples-3.1.3.jar wordcount -D mapreduce.job.queuename=hive /input /output5

也可以在打包之前的驱动指定向其他队列提交作业

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
public class WcDrvier {

public static void main(String[] args) throws IOException, ClassNotFoundException, InterruptedException {

Configuration conf = new Configuration();

conf.set("mapreduce.job.queuename","hive");

//1. 获取一个Job实例
Job job = Job.getInstance(conf);

。。。 。。。

//6. 提交Job
boolean b = job.waitForCompletion(true);
System.exit(b ? 0 : 1);
}
}

Yarn
https://xiamu.icu/Hadoop/Yarn/
作者
肉豆蔻吖
发布于
2023年1月31日
许可协议