You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues-all@impala.apache.org by "LiPenglin (Jira)" <ji...@apache.org> on 2022/06/09 11:37:00 UTC

[jira] [Commented] (IMPALA-11053) Impala should be able to read migrated partitioned Iceberg tables

    [ https://issues.apache.org/jira/browse/IMPALA-11053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17552144#comment-17552144 ] 

LiPenglin commented on IMPALA-11053:
------------------------------------

Hi [~boroknagyz] 

This is ok when a full table scan is performed.

However, the predicate in the WHERE clause does not work.
{code:java}
--- https://gerrit.cloudera.org/#/c/18240/11/testdata/workloads/functional-query/queries/QueryTest/iceberg-migrated-tables.test
[localhost.localdomain:21050] default> select * from functional_parquet.iceberg_alltypes_part where p_bool=false;
+---+--------+-------+----------+---------------+----------+-----------+------------+----------+
| i | p_bool | p_int | p_bigint | p_float       | p_double | p_decimal | p_date     | p_string |
+---+--------+-------+----------+---------------+----------+-----------+------------+----------+
| 1 | true   | 1     | 11       | 1.10000002384 | 2.222    | 123.321   | 2022-02-22 | impala   |
| 2 | true   | 1     | 11       | 1.10000002384 | 2.222    | 123.321   | 2022-02-22 | impala   |
+---+--------+-------+----------+---------------+----------+-----------+------------+----------+
Fetched 2 row(s) in 0.13s
[localhost.localdomain:21050] default> select * from functional_parquet.iceberg_alltypes_part where i=3;
+---+--------+-------+----------+---------------+----------+-----------+------------+----------+
| i | p_bool | p_int | p_bigint | p_float       | p_double | p_decimal | p_date     | p_string |
+---+--------+-------+----------+---------------+----------+-----------+------------+----------+
| 1 | true   | 1     | 11       | 1.10000002384 | 2.222    | 123.321   | 2022-02-22 | impala   |
| 2 | true   | 1     | 11       | 1.10000002384 | 2.222    | 123.321   | 2022-02-22 | impala   |
+---+--------+-------+----------+---------------+----------+-----------+------------+----------+
Fetched 2 row(s) in 0.16s {code}

> Impala should be able to read migrated partitioned Iceberg tables
> -----------------------------------------------------------------
>
>                 Key: IMPALA-11053
>                 URL: https://issues.apache.org/jira/browse/IMPALA-11053
>             Project: IMPALA
>          Issue Type: Bug
>            Reporter: Zoltán Borók-Nagy
>            Assignee: Zoltán Borók-Nagy
>            Priority: Major
>              Labels: impala-iceberg
>             Fix For: Impala 4.1.0
>
>
> When Hive (and probably other engines as well) converts a legacy Hive table to Iceberg it doesn't rewrite the data files.
> It means that the data files don't have write ids, moreover they don't have the partition columns neither.
> Currently Impala expects tha partition columns to be present in the data files, so it won't be able to read converted partitioned tables.
> So we need to inject partition values from the Iceberg metadata, plus resolve columns correctly (position-based resolution needs an offset).



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-all-unsubscribe@impala.apache.org
For additional commands, e-mail: issues-all-help@impala.apache.org