1.基本测试一
set mapred.reduce.tasks=-1;
set mapreduce.job.reduces=-1;
hive (hive_db)> insert overwrite local directory '/root/distribute_result1'
> select merid,money,name from store distribute by merid sort by money desc;
输出结果
set mapred.reduce.tasks=2;
set mapreduce.job.reduces=2;
hive (hive_db)> insert overwrite local directory '/root/distribute_result2'
> select merid,money,name from store distribute by merid sort by money desc;输出结果：
2.基本测试二