Hive优化高频面试题

server/2024/10/15 22:27:00/

文章目录

  • 一、开启本地模式
  • 二、explain分析sql语句
  • 三、修改Fetch操作
  • 四、开启hive的严格模式
  • 五、JVM重用
  • 六、分区、分桶以及压缩
  • 七、合理设置map和ruduce的数量
  • 八、设置并行执行
  • 九、CBO优化-成本优化器
  • 十、谓词下推
  • 十一、小表join大表--使用MapJoin
  • 十二、大表join大表--使用SMB Join
  • 十三、列裁剪与分区裁剪
  • 十四、避免数据倾斜
    • 1、数据倾斜的表现
    • 2、数据倾斜的原因和解决方案
      • 1)数据类型不一致造成数据倾斜
      • 2)数据中出现大量的null值
      • 3)单表group by 出现数据倾斜
    • 4)多表join出现数据倾斜


一、开启本地模式

数据量小的hive查询,集群模式浪费资源而且执行速度慢,此时可以开启本地模式,在单台机器上执行处理任务,执行时间会缩短。

二、explain分析sql语句

三、修改Fetch操作

Fetch抓取是指,Hive中对某些情况的查询可以不必使用MapReduce计算,在hive-site.xml文件中hive.fetch.task.conversion属性默认是more,在全局查找、字段查找、limit查找等都不走mapreduce

hive_13">四、开启hive的严格模式

防止写的烂sql影响集群,开启严格模式以后,以下情况多报SQL错误:
1)分区表不使用分区过滤
2)使用order by没有limit过滤
3)笛卡尔积不允许出现 (select * from emp,dept)

五、JVM重用

jvm重用就是一个虚拟机开启以后,执行多个task任务,再关闭。大大提高执行效率

六、分区、分桶以及压缩

压缩分为map阶段的压缩和reduce阶段的压缩
压缩格式有bzip2、gzip、snappy、lzo

七、合理设置map和ruduce的数量

当input文件很大,任务逻辑复杂,map执行非常慢的时候,可以增加map数量,使每个map处理的数据量减少,提高任务的执行效率
过多的启动和初始化reduce也会消耗时间和资源,所以需要合理的设置reduce的数量

八、设置并行执行

set hive.exec.parallel=true;
set hive.exec.parallel.thread.number=16;

九、CBO优化-成本优化器

可以自动优化HQL中多个Join的顺序,并选择合适的Join算法。

十、谓词下推

所谓的谓词下推就是将where条件提前执行,比如先执行where过滤,再进行join关联
通过谓词下推,过滤条件将在map端提前执行,减少了map端的输出,降低了数据IO,节约资源,提升性能。

十一、小表join大表–使用MapJoin

Map Join :小表进行缓存并发送到各个节点,将数据量小的表放在join的左边,在map端进行join,只有map没有reduce,所有没有Shuffle的过程

十二、大表join大表–使用SMB Join

分桶表join:创建两个分桶表,把大表的数据导入进去,然后让分桶表和分桶表进行join,速度会快,当然在执行之前,需要开启smb join的设置。

十三、列裁剪与分区裁剪

列裁剪就是在查询时只读取需要的列,分区裁剪就是只读取需要的分区。

-- 列裁剪
select name,age from emp;
-- 分区裁剪
select * from emp where dept='技术部';

十四、避免数据倾斜

1、数据倾斜的表现

数据倾斜是由于数据分布不均匀,造成数据大量的集中到一点,造成数据热点的现象。

2、数据倾斜的原因和解决方案

1)数据类型不一致造成数据倾斜

原因:两个表join时,on后面用来连接的两个字段类型不一致
解决办法:把类型转成一致的

如:

select * from users a join logs b on a.usr_id = cast(b.user_id as int)

2)数据中出现大量的null值

第一种情况:

null是异常值:比如userid出现null
解决方法:提前使用where过滤

如:

select * from (select * from user where id is not null) n join
bigtable o on n.id = o.id;

第二种情况:

出现null的数据不是异常数据,需要保留
解决方法:对应为null的数据随机赋一个表中不可能存在的值

如:

select n.* from nullidtable n full join bigtable o on  nvl(n.id,rand()) = o.id;

如果id为空,则赋一个0~1之间的随机数字,不包含1,这个数字是id列不可能出现的数字

3)单表group by 出现数据倾斜

原因:按照 Key 分组以后,少量的任务负责绝大部分数据

解决方法:
第一种:使用参数优化

当任务中存在group
by操作同时聚合函数为count或者sum时,可以使用Combine(运行在map端的reduce)操作,在map端提前进行聚合

-- 是否在Map端进行聚合,默认为True
set hive.map.aggr = true
-- 在Map端进行聚合操作的条目数目
set hive.groupby.mapaggr.checkinterval = 100000
-- 有数据倾斜的时候进行负载均衡(默认是false)
set hive.groupby.skewindata = true

第二种:

增加Reduce数量

4)多表join出现数据倾斜

大表join小表:

可以使用MapJoin,没有Reduce阶段就不会出现数据倾斜
还可以使用大表打散,小表扩容

大表join大表:

使用smb join:
分桶表join:创建两个分桶表,把大表的数据导入进去,然后让分桶表和分桶表进行join,速度会快,当然在执行之前,需要开启smb join的设置。


http://www.ppmy.cn/server/123205.html

相关文章

录屏小白福音!三款神器助你轻松上手

生活工作中,需要借助录屏功能越来越家常便饭了,选择录屏软件时,主要考虑的是软件的易用性、功能以及用户评价等因素。以下是如何进行录屏的步骤,以及推荐的四个录屏软件的使用说明:关于如何录屏的步骤操作,…

基于Springboot农耕知识查询平台JAVA|VUE|SSM计算机毕业设计源代码+数据库+LW文档+开题报告+答辩稿+部署教+代码讲解

源代码数据库LW文档(1万字以上)开题报告答辩稿 部署教程代码讲解代码时间修改教程 一、开发工具、运行环境、开发技术 开发工具 1、操作系统:Window操作系统 2、开发工具:IntelliJ IDEA或者Eclipse 3、数据库存储&#xff1a…

【计算机网络 - 基础问题】每日 3 题(二十八)

✍个人博客:Pandaconda-CSDN博客 📣专栏地址:http://t.csdnimg.cn/fYaBd 📚专栏简介:在这个专栏中,我将会分享 C 面试中常见的面试题给大家~ ❤️如果有收获的话,欢迎点赞👍收藏&…

【React】JSX基础知识

1. JSX的本质 JSX并不是标准的js语法,而是js语法扩展,浏览器本身无法识别,需要进行解析。解析工具:babel 2. JSX使用的4个高频场景 使用引号传递字符串使用js变量函数调用和方法调用使用js对象 function App() {const jsVar …

opencv学习:通过图像透视进行发票识别完整代码流程

概念: 使用OpenCV库实现图像的透视变换处理,以矫正图像中的透视失真。通过本实验,学习者将掌握图像处理的基本操作,包括图像的读取、显示、大小调整、灰度转换、二值化、轮廓检测、轮廓近似以及透视变换。 步骤: 1. …

pycharm2024版 搭配Anaconda创建pytorch项目

pycharm2024版 搭配Anaconda创建pytorch项目 ​ 刚接触anaconda和pytorch,b站看的教学视频中博主使用的是2019版的pycharm,所以在创建pytorch项目时有些懵,在多次摸索后大概明白了一些 上图中是2024版pycharm的新项目创建界面 Project venv…

众数问题,

在本实验中&#xff0c;需要编写一个程序来处理一组输入数据&#xff0c;找出其中的众数&#xff0c;即出现次数最多的数字。程序会读取文件中的数据进行处理&#xff0c;并将结果与标准答案进行比对&#xff0c;判断程序输出是否正确。 #include <bits/stdc.h> #define …

集成Elasticsearch到django restful

文章目录 集成ES到django restful服务端项目安装haystack基本使用安装配置索引模型ORM模型中新增discount_json字段方法全文索引字段模板 索引序列化器全文搜索的索引视图路由手动构建es索引 集成ES到django restful服务端项目 如果直接在Django项目直接编写代码作为ElasticSe…