这里由于没有名字为root.nexttao的队列,规则1、2都没有匹配上,随意提交到了root.default队列 b 用nexttao的用户设置任务队列为root.tracy后提交一个mapreduce任务: hadoop jar hadoop-examples.jar wordcount -Dmapred.reduce.tasks=1 -Dmapred.job.queue.name=root.tracy hdfs://Spark-Test-1:8020/test/input hdfs://Spark-Test-1:8020/test/output
这里在设置了队列后,走了规则1,如图 c 用tracy用户不设置队列的情况下提交一个mapreduce任务 hadoop jar hadoop-examples.jar wordcount -Dmapred.reduce.tasks=1 hdfs://Spark-Test-1:8020/test/input hdfs://Spark-Test-1:8020/test/output