2

我正在尝试创建一个按单个字段分区的配置单元表。我要处理的数据是日志数据。日志格式为：

日期时间 IPAddress HTTP_METHOD MESSAGE

创建表配置单元查询：

CREATE EXTERNAL TABLE test_Part(
logdate string,
logtime string,
ip string,
message string)
PARTITIONED BY(method string)
ROW FORMAT SERDE 'org.apache.hadoop.hive.serde2.RegexSerDe'
WITH SERDEPROPERTIES (
"input.regex" = "(\\d{4}-\\d{2}-\\d{2})\\s(\\d{2}:\\d{2}:\\d{2})\\s(\\d+\\.\\d+\\.\\d+\\.\\d+)\\s(\\S+)\\s(.*$)",
"output.format.string" = "%1$s %2$s %3$s %5$s %4$s"
)
STORED AS TEXTFILE;

并加载脚本：

LOAD DATA LOCAL INPATH '/home/user/tools/apache-hive-1.2.2-bin/scripts/sample1.log' OVERWRITE INTO TABLE test_Part PARTITION(method='GET');

当我在上表上运行选择查询时，它给了我错误消息

因异常 java.io.IOException:org.apache.hadoop.hive.serde2.SerDeException 失败：匹配组的数量与列的数量不匹配

我错过了什么？

4

2 回答 2

1

分区反映了一种情况，其中以特定值（分区列值）为特征的行可以直接访问，而无需访问其他不必要的数据。
这显然不是这里的情况，所以你不能在你的数据文件上声明一个分区表。

从这一点开始，您可以执行以下操作：

1.

省略分区。

CREATE EXTERNAL TABLE test_Part_stg(
logdate string,
logtime string,
ip string,
method string,
message string)
ROW FORMAT SERDE 'org.apache.hadoop.hive.serde2.RegexSerDe'
WITH SERDEPROPERTIES (
"input.regex" = "(\\d{4}-\\d{2}-\\d{2})\\s(\\d{2}:\\d{2}:\\d{2})\\s(\\d+\\.\\d+\\.\\d+\\.\\d+)\\s(\\S+)\\s(.*$)"
)
STORED AS TEXTFILE;

2.（可选）

创建一个额外的分区表并使用上一步中的表填充它。

（这个表存储不一定是TEXTFILE）

CREATE EXTERNAL TABLE test_Part(
logdate string,
logtime string,
ip string,
message string)
PARTITIONED BY(method string)
STORED AS TEXTFILE;

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

insert into test_Part partition (method)
select logdate,logtime,ip,message,method 
from   test_Part_stg
;

或者

insert into test_Part partition (method) (logdate,logtime,ip,method,message)
select * 
from   test_Part_stg
;

附言

output.format.string已弃用，它未在 RegexSerDe 中定义，并且与任何其他未定义的 SerDe 参数一样没有功能意义。

于 2017-07-04T05:47:43.820 回答
0

应该是 4 个组，因为表 DDL 中有 4 列。在您的正则表达式中有 5 个组。method是一个分区（包含文件的目录），该列通常不存在于文件本身中，您不需要在正则表达式中指定它。

分区存储为包含分区位置和键值的元数据。位置看起来像 table_dir/method=GET/

在此处查看很好的示例：http: //www.dowdandassociates.com/blog/content/howto-use-hive-with-apache-logs/

如果文件中还存在分区列，则应在表定义中添加更多列。似乎列存在。是 HTTP_METHOD 吗？然后只需在消息列之前再添加一列 HTTP_METHOD 并再次检查您的正则表达式。

于 2017-07-03T19:28:08.190 回答