[
https://issues.apache.org/jira/browse/CARBONDATA-2631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rahul Kumar updated CARBONDATA-2631:
------------------------------------
Description:
*CTAS from Hive table:*
spark.sql({color:#008000}"drop table if exists hive_tprop"{color})
spark.sql({color:#008000}"CREATE TABLE IF NOT EXISTS hive_tprop ( eid int, name
String,salary String, destination String,doj date, toj timestamp, abc
decimal(8,2), test BIGINT) stored by 'carbondata'
TBLPROPERTIES('DICTIONARY_INCLUDE'='eid','DICTIONARY_EXCLUDE'='name','No_Inverted_Index'='name','SORT_SCOPE'='global_sort')"{color})
spark.sql({color:#008000}"insert into hive_tprop select
1,'rev','1000','ban','1999-01-12','1999-02-10
05:25:00',123456.25,564789"{color})
spark.sql({color:#008000}"insert into hive_tprop select
2,'rev','1000','ban','2012-01-01','2012-02-10
05:25:00',123456.25,564789"{color})
spark.sql({color:#008000}"alter table hive_tprop add columns (new_col1
INT)"{color})
spark.sql({color:#008000}"update hive_tprop set (eid)=(3)"{color}).show()
spark.sql({color:#008000}"select * from hive_tprop"{color}).show()
was:
*CTAS from Hive table:*
drop table if exists employee_h;
CREATE TABLE IF NOT EXISTS employee_h ( eid int, name String,salary String,
destination String,doj date, toj timestamp, abc decimal(8,2), test BIGINT) row
format delimited fields terminated by ',';
insert into employee_h select 1,'rev','1000','ban','1999-01-12','1999-02-10
05:25:00',123456.25,564789;
insert into employee_h select 2,'rev','1000','ban','2012-01-01','2012-02-10
05:25:00',123456.25,564789;
select * from employee_h;
drop table if exists hive_tprop;
create table hive_tprop stored by 'carbondata'
TBLPROPERTIES('DICTIONARY_INCLUDE'='eid','DICTIONARY_EXCLUDE'='name','No_Inverted_Index'='name','SORT_SCOPE'='global_sort')
as select eid , name ,salary, destination, doj, toj, abc, test from employee_h;
describe formatted hive_tprop;
select * from hive_tprop;
alter table hive_tprop rename to hive_tprop1;
alter table hive_tprop1 rename to hive_tprop;
alter table hive_tprop add columns (new_col string);
alter table hive_tprop add columns (new_col1 int);
alter table hive_tprop change new_col1 new_col1 BIGINT;
alter table hive_tprop change abc abc decimal(9,3);
select * from hive_tprop limit 1;
insert into hive_tprop select 1,'rev','1000','ban','1999-01-12','1999-02-10
05:25:00',123456.25,564789,'revathi',12346;
update hive_tprop set (eid)=(3);
> Update on the CTAS table is failing sporadically.
> --------------------------------------------------
>
> Key: CARBONDATA-2631
> URL: https://issues.apache.org/jira/browse/CARBONDATA-2631
> Project: CarbonData
> Issue Type: Improvement
> Reporter: Rahul Kumar
> Assignee: Rahul Kumar
> Priority: Major
>
> *CTAS from Hive table:*
> spark.sql({color:#008000}"drop table if exists hive_tprop"{color})
> spark.sql({color:#008000}"CREATE TABLE IF NOT EXISTS hive_tprop ( eid int,
> name String,salary String, destination String,doj date, toj timestamp, abc
> decimal(8,2), test BIGINT) stored by 'carbondata'
> TBLPROPERTIES('DICTIONARY_INCLUDE'='eid','DICTIONARY_EXCLUDE'='name','No_Inverted_Index'='name','SORT_SCOPE'='global_sort')"{color})
> spark.sql({color:#008000}"insert into hive_tprop select
> 1,'rev','1000','ban','1999-01-12','1999-02-10
> 05:25:00',123456.25,564789"{color})
> spark.sql({color:#008000}"insert into hive_tprop select
> 2,'rev','1000','ban','2012-01-01','2012-02-10
> 05:25:00',123456.25,564789"{color})
> spark.sql({color:#008000}"alter table hive_tprop add columns (new_col1
> INT)"{color})
> spark.sql({color:#008000}"update hive_tprop set (eid)=(3)"{color}).show()
> spark.sql({color:#008000}"select * from hive_tprop"{color}).show()
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
