设为首页 加入收藏

TOP

HIVE的十项企业级调优
2019-05-11 02:05:49 】 浏览:55
Tags:HIVE 企业级

话不多说直接上货。

1.Fetch抓取

set hive.fetch.task.conversion=more(默认)

Fetch 抓取是指,Hive 中对某些情况的查询可以不必使用 MapReduce 计算。

该属性设置为 more 以后,在全局查找、字段查找、limit 查找等都不走 MapReduce。 设置为none后所有类型的查找语句都要走MapReduce;

2.本地模式

set hive.exec.mode.local.auto=true(开启本地模式)

Hive 可以通过本地模式在单台机器上 处理所有的任务。对于小数据集,执行时间可以明显被缩短

①开启本地模式后需要设置local mr的最大输入数据量,当数据量小于这个值时采用local mr的方式

set hive.exec.mode.local.auto.inputbytes.max=134217728(默认)

②开启本地模式后需要设置local mr的最大输入文件个数,当数据量小于这个值时采用local mr的方式

set hive.exec.mode.local.auto.input.files.max=4(默认)

3.表的优化

3.1小表join大表 (小表需要在左边.)

注:(新版的 hive 已经对小表 JOIN 大表和大表 JOIN 小表进行了优化。小表 放在左边和右边已经没有明显区别。)

3.2大表join大表

当一个表内有许多空值时会导致MapReduce过程中,空成为一个key值,对应的会有大量的value值, 而一个key的value会一起到达reduce造成内存不足;所以要想办法过滤这些空值.

(1).通过查询所有不为空的结果

insert overwrite table jointable select n.* from

(select * from nullidtable where id is not null ) n left join ori o on n.id = o.id;

(2).查询出空值并给其赋上随机数,避免了key值为空

insert overwrite table jointable

select n.* from nullidtable n full join ori o on

case when n.id is null then concat(‘hive’, rand()) else n.id end = o.id;

注:此方法可以解决数据倾斜的问题

3.3MapJoin

如果不指定 MapJoin 或者不符合 MapJoin 的条件,那么 Hive 解析器会将 Join 操作转换成 Common Join,即:在 Reduce 阶段完成 join。容易发生数据倾斜。可以用 MapJoin 把小 表全部加载到内存在 map 端进行 join,避免 reducer 处理。

设置MapJoin

set hive.auto.convert.join = true(默认)

大表小表的阀门值设置(默认25M以下认为是小表):

set hive.mapjoin.smalltable.filesize=25000000;

3.4Group BY

默认情况下,Map 阶段同一 Key 数据分发给一个 reduce,当一个 key 数据过大时就倾斜了并不是所有聚合都在reduce端完成,很多聚合操作都可以现在Map端进行部分聚合,最后在Reduce段得到结果

开启Map端聚合参数设置

是否在Map段进行聚合,默认为true

hive.map.aggr = true

在Map端进行聚合操作的条目数

hive.groupby.mapaggr.checkinterval = 100000

有数据倾斜的时候进行负载均衡(默认是false)

hive.groupby.skewindata = true

注:当选项设定为 true,生成的查询计划会有两个 MR Job。第一个 MR Job 中,Map 的输出结果会随机分布到 Reduce 中,每个 Reduce 做部分聚合操作,并输出结果,这样处理的结果是相同的 Group By Key 有可能被分发到不同的 Reduce 中,从而达到负载均衡的目的;第二个 MR Job 再根据预处理的数据结果按照 Group By Key 分布到 Reduce 中(这个过程可以 保证相同的 Group By Key 被分布到同一个 Reduce 中),最后完成最终的聚合操作。

3.5Count(Distinct)去重统计

Count Distinct是使用了一个mapreduce ,当数据较少时无影响当数据较大时 只使用一个MapReduce将很难完成job。这是需要用到分组 Group BY 会使用2个MapReduce完成因为设置了 set mapreduce.job.reduces = 5; 所以第一个MapReduce的过程是通过一个map和5个reduce来完成这样减轻了reduce的负载, 虽然会多用一个 Job 来完成,但在数据量大的情况下,这个绝对是值得的。

3.6.行列过滤

列处理: 在select中,只拿需要的列,尽量使用分区过滤,少用select*

行处理: 在分区剪裁中,当使用外关联时,如果将副表的过滤条件写在where后面那么就会先全表关联,之后再过滤。

实例:

(1)测试先关联两张表,再用 where 条件过滤

hive (default)> select o.id from bigtable bjoin ori o on o.id = b.idwhere o.id <= 10;

(2)通过子查询后,再关联表

hive (default)> select b.id from bigtable bjoin (select id from ori where id <= 10 ) o on b.id = o.id;

3.7.动态分区

关系型数据库中,对分区表 Insert 数据时候,数据库自动会根据分区字段的值,将数据插入到相应的分区中,Hive 中也提供了类似的机制,即动态分区(Dynamic Partition),只不过,使用 Hive 的动态分区,需要进行相应的配置。

首先要设置的属性

set hive.exec.dynamic.partition = true;

set hive.exec.dynamic.partition.mode = nonstrict;

set hive.exec.max.dynamic.partitions = 1000;

set hive.exec.max.dynamic.partitions.pernode = 100;

set hive.exec.max.created.files = 100000;

set hive.error.on.empty.partition = false;

模拟动态分区

insert overwrite table ori_partitioned_target partition (p_time)

select id, time, uid, keyword, url_rank, click_num, click_url, p_time from ori_partitioned;

4.数据倾斜

4.1合理设置Map数

设置切片值: set mapreduce.input.fileinputformat.split.maxsize=

4.2小文件进行合并

在 map 执行前合并小文件,减少 map 数:CombineHiveInputFormat 具有对小文件进行

合并的功能(系统默认的格式)。HiveInputFormat 没有对小文件合并功能。

set hive.input.format= org.apache.hadoop.hive.ql.io.CombineHiveInputFormat;

4.3复杂文件增加Map数

set mapreduce.job.maps

4.4合理设置Reduce数

①调整reduce的个数方法一

(1)每个Reduce处理的数据默认是256MB

hive.exec.reducers.bytes.per.reducer=256000000

(2)每个任务最大的reduce数,默认为1009

hive.exec.reducers.max=1009

(3)计算reduce数的公式

N=min(参数2,总输入数据量/参数1)

②调整reduce个数的方法二

set mapreduce.job.reduces=

③reduce个数不是越多越好

1)过多的启动和初始化 reduce 也会消耗时间和资源;

2)另外,有多少个 reduce,就会有多少个输出文件,如果生成了很多个小文件,那么如果这些小文件作为下一个任务的输入,则也会出现小文件过多的问题;在设置 reduce 个数的时候也需要考虑这两个原则:处理大数据量利用合适的 reduce 数;使单个 reduce 任务处理数据量大小要合适;

4.5并行执行

通过设置参数 hive.exec.parallel 值为 true,就可以开启并发执行。不过,在共享集群中,需要注意下,如果 job 中并行阶段增多,那么集群利用率就会增加。

①set hive.exec.parallel=true; //打开任务并行执行

①set hive.exec.parallel.thread.number=16; //同一个 sql 允许最大并行度,默认为 8。

4.6严格模式

没写完明天继续更。

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇mystock 下一篇数据结构三.用链表实现栈

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目