You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@kudu.apache.org by "Todd Lipcon (JIRA)" <ji...@apache.org> on 2016/04/26 21:22:13 UTC
[jira] [Assigned] (KUDU-1429) data type confusion between kudu and
impala tables
[ https://issues.apache.org/jira/browse/KUDU-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Todd Lipcon reassigned KUDU-1429:
---------------------------------
Assignee: Casey Ching
Casey, do you mind having a look at this?
> data type confusion between kudu and impala tables
> --------------------------------------------------
>
> Key: KUDU-1429
> URL: https://issues.apache.org/jira/browse/KUDU-1429
> Project: Kudu
> Issue Type: Bug
> Components: impala
> Affects Versions: 0.8.0
> Reporter: nick
> Assignee: Casey Ching
> Priority: Critical
>
> CREATE TABLE ppo_test1 (
> ts_id SMALLINT,
> input_seq BIGINT,
> output_seq BIGINT,
> d_id INT,
> input_id SMALLINT,
> output_id SMALLINT,
> input_value DOUBLE,
> audit_id INT,
> is_uo TINYINT
> ) TBLPROPERTIES (
> 'kudu.master_addresses'='master:7051',
> 'kudu.num_tablet_replicas'='3',
> 'kudu.key_columns'='ts_id,input_seq,output_seq',
> 'kudu.table_name'='ppo_test1',
> 'storage_handler'='com.cloudera.kudu.hive.KuduStorageHandler');
>
> CREATE TABLE temp_4141 (
> input_seq BIGINT,
> output_seq BIGINT,
> d_id INT,
> input_id SMALLINT,
> output_id SMALLINT,
> input_value DOUBLE,
> audit_id INT,
> is_uo BOOLEAN,
> ts_id SMALLINT
> ) ROW FORMAT DELIMITED FIELDS TERMINATED BY '|' STORED AS TEXTFILE;
> [impala07:21000] > select * from ppo_test1;
> Query: select * from ppo_test1
> +-------+--------------------+--------------------+-----------+----------+-----------+-------------+----------+-------+
> | ts_id | input_seq | output_seq | d_id | input_id | output_id | input_value | audit_id | is_uo |
> +-------+--------------------+--------------------+-----------+----------+-----------+-------------+----------+-------+
> | 253 | 158236666882949127 | 158800218131791879 | 7 | 562 | 564 | 1432.777832 | 441 | 0 |
> | 253 | 158236666882949128 | 158800218131791880 | 8 | 562 | 564 | 111 | 325 | 0 |
> | 253 | 158236666882949129 | 158800218131791881 | 9 | 562 | 564 | 1403.632446 | 441 | 0 |
> | 253 | 158236666882949130 | 158800218131791882 | 10 | 562 | 564 | 1452.579346 | 441 | 0 |
> | 253 | 158236666882949131 | 158800218131791883 | 11 | 562 | 564 | 1545.86084 | 441 | 0 |
> | 295 | 158518141859661663 | 158518923543709535 | 1887 | 563 | 563 | 1394.196899 | 591 | 0 |
> | 295 | 159925516743214944 | 159926298427262816 | 1888 | 568 | 568 | 1317.554688 | 591 | 0 |
> | 295 | 164429116370585440 | 164429898054633312 | 1888 | 584 | 584 | 1313.598755 | 591 | 0 |
> | 295 | 164992066324006752 | 164992848008054624 | 1888 | 586 | 586 | 1313.598511 | 591 | 0 |
> +-------+--------------------+--------------------+-----------+----------+-----------+-------------+----------+-------+
> Fetched 9 row(s) in 0.17s
> [impala07:21000] > select * from temp_4141;
> Query: select * from temp_4141
> +--------------------+--------------------+------+----------+-----------+-------------+----------+-------+-------+
> | input_seq | output_seq | d_id | input_id | output_id | input_value | audit_id | is_uo | ts_id |
> +--------------------+--------------------+------+----------+-----------+-------------+----------+-------+-------+
> | 164992066324006752 | 164992848008054624 | 1888 | 586 | 586 | 1313.598511 | 965 | false | 295 |
> | 164429116370585440 | 164429898054633312 | 1888 | 584 | 584 | 1313.598755 | 965 | false | 295 |
> | 159925516743214944 | 159926298427262816 | 1888 | 568 | 568 | 1317.554688 | 965 | false | 295 |
> | 160488466696636256 | 160489248380684128 | 1888 | 570 | 570 | 1314.795288 | 965 | false | 295 |
> | 158518141859661663 | 158518923543709535 | 1887 | 563 | 563 | 1394.196899 | 965 | false | 295 |
> +--------------------+--------------------+------+----------+-----------+-------------+----------+-------+-------+
> Fetched 5 row(s) in 0.93s
> [impala07:21000] > DELETE ppo from ppo_test1 ppo where output_seq in (select distinct output_seq FROM temp_4141);
> Query: delete ppo from ppo_test1 ppo where output_seq in (select distinct output_seq FROM temp_4141)
> WARNINGS:
> Could not add Kudu WriteOp.: Invalid argument: invalid type int64 provided for column 'ts_id' (expected int16)
> Could not add Kudu WriteOp.: Invalid argument: invalid type int64 provided for column 'ts_id' (expected int16)
> [impala07:21000] >
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)