Hive-调优，Fetch抓取，本地模式

╰+攻爆jí腚メ 2023-03-06 03:37 71阅读 0赞

# Hive-调优，Fetch抓取，本地模式 #

### 文章目录 ###

*  Hive-调优，Fetch抓取，本地模式
 *   *  Fetch抓取
     *  本地模式

## Fetch抓取 ##

Fetch抓取是指，Hive中对某些情况的查询可以不必使用MapReduce计算。例如：`SELECT * FROM emp;`在这种情况下，Hive可以简单地读取emp对应的存储目录下的文件，然后输出查询结果到控制台。

`hive.fetch.task.conversion`默认是more，老版本 Hive 默认是 minimal（Minimal，查询分区表不走MR）

*  none：执行任何查询都走mapreduce
 *  minimal：执行（单个分区表）全局查找（select \* ）、字段查找、limit不走mapreduce，不加分区字段执行会走MR
 *  more：执行（无论是否有分区表）全局查找（select \* ）、字段查找、limit都不走mapreduce

<property>
        <name>hive.fetch.task.conversion</name>
        <value>more</value>
        <description>
          Expects one of [none, minimal, more].
          Some select queries can be converted to single FETCH task minimizing latency.
          Currently the query should be single sourced not having any subquery and should not have any aggregations or distincts (which incurs RS), lateral views and joins.
          0. none : disable hive.fetch.task.conversion
          1. minimal : SELECT STAR, FILTER on partition columns, LIMIT only
          2. more  : SELECT, FILTER, LIMIT only (support TABLESAMPLE and virtual columns)
        </description>
    </property>

**案例测试：**

（1）把`hive.fetch.task.conversion`设置成minimal，然后执行查询语句。

hive (default)> set hive.fetch.task.conversion=minimal;
    -- 会执行MR
    hive (default)> select * from logs;
    hive (default)> select logid from logs;
    hive (default)> select logid from logs limit 3;
    -- 不会执行MR
    hive (default)> select * from logs where day='20200701';
    hive (default)> select logid from logs where day='20200701';
    hive (default)> select logid from logs where day='20200701' limit 3;

（2）把`hive.fetch.task.conversion`设置成more，如下查询方式不会执行mapreduce程序。

hive (default)> set hive.fetch.task.conversion=more;
    -- 都不会执行MR
    -- 不会执行MR
    hive (default)> select * from logs;
    hive (default)> select logid from logs;
    hive (default)> select logid from logs limit 3;
    -- 不会执行MR
    hive (default)> select * from logs where day='20200701';
    hive (default)> select logid from logs where day='20200701';
    hive (default)> select logid from logs where day='20200701' limit 3;

## 本地模式 ##

大多数的Hadoop Job是需要Hadoop提供的完整的可扩展性来处理大数据集的。不过，有时Hive的输入数据量是非常小的。  
在这种情况下，为查询触发执行任务消耗的时间可能会比实际job的执行时间要多的多。  
对于大多数这种情况，Hive可以通过本地模式在单台机器上处理所有的任务。对于小数据集，执行时间可以明显被缩短。

用户可以通过设置`hive.exec.mode.local.auto`的值为true，来让Hive在适当的时候自动启动这个优化。

-- 开启本地MR
    set hive.exec.mode.local.auto=true;
    -- 设置local mr的最大输入数据量，当输入数据量小于这个值时采用local  mr的方式，默认为134217728，即128M
    set hive.exec.mode.local.auto.inputbytes.max=50000000;
    -- 设置local mr的最大输入文件个数，当输入文件个数小于这个值时采用local mr的方式，默认为4
    set hive.exec.mode.local.auto.input.files.max=10;

**案例测试：**

（1）开启本地模式，并执行查询语句

hive (default)> set hive.exec.mode.local.auto=true; 
    hive (default)> select * from emp cluster by deptno;
    
    Time taken: 1.328 seconds, Fetched: 14 row(s)

（2）关闭本地模式，并执行查询语句

hive (default)> set hive.exec.mode.local.auto=false; 
    hive (default)> select * from emp cluster by deptno;
    
    Time taken: 20.09 seconds, Fetched: 14 row(s)