[
https://issues.apache.org/jira/browse/KUDU-1429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Casey Ching updated KUDU-1429:
------------------------------
Comment: was deleted
(was: Thanks for reporting this Nick. I'm moving this to the Impala bug
tracker. https://issues.cloudera.org/browse/IMPALA-3454
I found the problem. This will be fixed in the 0.9 release.
As a workaround, you'd need to rewrite any delete statements that have
subqueries an non-subquery statements. In the example above that would be
"delete p from ppo_test1 p left semi join temp_4141 t on t.output_seq =
p.output_seq".)
> 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
> Fix For: 0.9.0
>
>
> 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)
