You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@hive.apache.org by "Sergio Peña (JIRA)" <ji...@apache.org> on 2015/03/25 17:31:55 UTC
[jira] [Created] (HIVE-10086) Hive throws error when accessing
Parquet file schema using field name match
Sergio Peña created HIVE-10086:
----------------------------------
Summary: Hive throws error when accessing Parquet file schema using field name match
Key: HIVE-10086
URL: https://issues.apache.org/jira/browse/HIVE-10086
Project: Hive
Issue Type: Bug
Affects Versions: 1.0.0
Reporter: Sergio Peña
Assignee: Sergio Peña
When Hive table schema contains a portion of the schema of a Parquet file, then the access to the values should work if the field names match the schema. This does not work when a struct<> data type is in the schema, and the Hive schema contains just a portion of the struct elements. Hive throws an error instead.
This is the example and how to reproduce:
First, create a parquet table, and add some values on it:
{code}
CREATE TABLE test1 (id int, name string, address struct<number:int,street:string,zip:string>) STORED AS PARQUET;
INSERT INTO TABLE test1 SELECT 1, 'Roger', named_struct('number',8600,'street','Congress Ave.','zip','87366') FROM srcpart LIMIT 1;
{code}
Note: {{srcpart}} could be any table. It is just used to leverage the INSERT statement.
The above table example generates the following Parquet file schema:
{code}
message hive_schema {
optional int32 id;
optional binary name (UTF8);
optional group address {
optional int32 number;
optional binary street (UTF8);
optional binary zip (UTF8);
}
}
{code}
Afterwards, I create a table that contains just a portion of the schema, and load the Parquet file generated above, a query will fail on that table:
{code}
CREATE TABLE test1 (name string, address struct<street:string>) STORED AS PARQUET;
LOAD DATA LOCAL INPATH '/tmp/HiveGroup.parquet' OVERWRITE INTO TABLE test1;
hive> SELECT name FROM test1;
OK
Roger
Time taken: 0.071 seconds, Fetched: 1 row(s)
hive> SELECT address FROM test1;
OK
Failed with exception java.io.IOException:org.apache.hadoop.hive.ql.metadata.HiveException: java.lang.UnsupportedOperationException: Cannot inspect org.apache.hadoop.io.IntWritable
Time taken: 0.085 seconds
{code}
I would expect that Parquet can access the matched names, but Hive throws an error instead.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)