nick created KUDU-1429:
--------------------------
Summary: 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
Affects Versions: 0.8.0
Reporter: nick
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)
