Hive动态分区insert详解

一、hive动态分区insert报错

在进行hive动态分区insert操作时，可能遇到各种报错，比如分区字段不对应、分区字段值为空、重复插入等。为避免这些报错，我们需要掌握动态分区的使用方法和注意事项。

首先，在建表时需要指定分区字段，然后在进行insert操作时，使用以下语句进行动态分区插入：

insert overwrite table table_name partition(partition_column)
values(partition_value, column1_value, column2_value,...)

其中partition_column为分区字段名，partition_value为要插入的分区字段的具体值，column1、column2等表示要插入的普通列值。需要注意的是，在values括号中分别填入分区字段的值和普通列的值。

二、hive动态分区多字段

有时候我们需要在一个表中按照不同字段进行分区，这时就需要使用多字段动态分区。建表时需要按照以下格式指定分区字段：

partitioned by (partition_column1 datatype1, partition_column2 datatype2,...)

其中，partition_column1、partition_column2等表示分区字段名，datatype1、datatype2等表示数据类型。在进行insert操作时，使用以下语句进行多字段动态分区插入：

insert overwrite table table_name partition(partition_column1=value1, partition_column2=value2,...)
values(column1_value, column2_value,...)

可以看到，values括号内只填入普通列的值，而动态分区的值则在partition关键字后以“partition_column=value”的形式进行指定。

三、hive动态分区最大个数

在进行分区操作时，有可能遇到最大分区数的限制。在hive中，默认最大分区数为100，这意味着我们最多只能使用100个分区字段。如果需要使用更多的分区字段，可以通过hive设置动态分区个数进行修改。具体操作如下：

SET hive.exec.dynamic.partition=true;
SET hive.exec.dynamic.partition.mode=nonstrict;
SET hive.exec.max.dynamic.partitions=200000;
SET hive.exec.max.dynamic.partitions.pernode=100000;

可以看到，需要先开启动态分区功能，然后设置分区模式为非严格模式。之后设置最大动态分区数为200000，其中每个节点最大动态分区数为100000。通过这样的设置，我们就能够使用更多的分区字段进行动态分区插入了。

四、hive动态分区参数

除了分区字段和普通列的值外，我们还可以在动态分区插入时进行一些参数设置，以满足一些特殊的需求。比如，在进行数据清洗时，可能需要给分区添加一些时间戳，可以使用以下语句：

insert overwrite table table_name partition(partition_column=value,dt='${date}')
values(column1_value, column2_value,...)

其中，dt='${date}'就是一个参数设置，它会根据系统时间生成当前日期，然后插入到分区字段中。在进行动态分区插入时，我们还可以使用其他的参数，比如${hiveconf:parameter_name}这个语法用于引用Hive的系统参数。需要注意的是，在使用参数时，需要在动态分区插入语句中用单引号把参数引起来。

五、hive动态分区100限制

在开启动态分区之后，我们可能会遇到一些插入分区的限制，那就是每次只能插入100个分区。这个限制是为了避免一些特殊情况下的风险，比如数据不均匀、末尾分区特别多等。如果确实需要插入更多的分区，可以使用以下两种方式：

1. 在每次插入时，只插入部分分区，然后再循环执行插入操作，直到所有分区插入完成。这种方式比较麻烦，但是能够有效地避免风险。

insert overwrite table table_name partition(partition_column)
values
('partition_value1',column1_value,column2_value,...),
('partition_value2',column1_value,column2_value,...),
...
('partition_value100',column1_value,column2_value,...);

insert overwrite table table_name partition(partition_column)
values
('partition_value101',column1_value,column2_value,...),
('partition_value102',column1_value,column2_value,...),
...
('partition_value200',column1_value,column2_value,...);

2. 在进行分区插入之前，先设置hive.exec.max.dynamic.partitions.hivevar参数，以增加允许插入分区的最大个数。需要注意的是，在使用这种方式时，必须在分区列中指定所有可能出现的分区值，否则仍有可能会出现插入失败的情况。

SET hive.exec.dynamic.partition=true;
SET hive.exec.dynamic.partition.mode=nonstrict;
SET hive.exec.max.dynamic.partitions.hivevar=200000;

六、hive动态分区和静态分区

除了动态分区插入方式外，Hive还支持静态分区插入。静态分区插入是指在开始数据导入之前，就确定好所有的分区字段值，然后直接向指定分区插入数据。与动态分区插入相比，静态分区插入的主要优点就是分区数据是确定的，不容易出现分布不均或者分区数过多等问题。

静态分区插入的语法格式如下：

insert overwrite table table_name partition(partition_column1=value1, partition_column2=value2,...)
select column1,column2,...from source_table where condition;

可以看到，静态分区插入是通过select语句来进行数据查询的，其中partition_column1、partition_column2等表示分区字段，value1、value2等表示分区字段的具体值。在from关键字后指定数据源表名，where后可添加限制条件。静态分区插入的参数设置与动态分区大致相同，只是插入时不需要再进行动态赋值。