From the data loading log, I find this table is not a carbon table.
Need to create carbon table and load data again.
-- --
??: "??";;
: 2016??7??5??(??) 4:17
??: "caiqiang";
: scala> cc.sql(s"load data inpath 'hdfs:/
scala> cc.sql(s"load data inpath
'hdfs://cdncluster/tmp/csv-panda_quality_v1_20160625/part-0.csv' into table
williamtable02")
INFO 05-07 16:11:30,316 - main Query [LOAD DATA INPATH
'HDFS://CDNCLUSTER/TMP/CSV-PANDA_QUALITY_V1_20160625/PART-0.CSV' INTO TABLE
WILLIAMTABLE02]
INFO 05-07 16:11:30,379 -
INFO 05-07 16:11:30,379 -
INFO 05-07 16:11:30,379 -
INFO 05-07 16:11:30,411 -
INFO 05-07 16:11:30,414 - Parsing command: load data inpath
'hdfs://cdncluster/tmp/csv-panda_quality_v1_20160625/part-0.csv' into table
williamtable02
INFO 05-07 16:11:31,203 - Parse Completed
INFO 05-07 16:11:31,204 -
INFO 05-07 16:11:31,206 -
INFO 05-07 16:11:31,254 - 0: get_table : db=default tbl=williamtable02
INFO 05-07 16:11:31,254 - ugi=allwefantasy ip=unknown-ip-addr
cmd=get_table : db=default tbl=williamtable02
INFO 05-07 16:11:31,572 - Semantic Analysis Completed
INFO 05-07 16:11:31,572 -
INFO 05-07 16:11:31,579 - Returning Hive schema: Schema(fieldSchemas:null,
properties:null)
INFO 05-07 16:11:31,579 -
INFO 05-07 16:11:31,579 - Concurrency mode is disabled, not creating a lock
manager
INFO 05-07 16:11:31,580 -
INFO 05-07 16:11:31,580 - Starting
command(queryId=allwefantasy_20160705161130_e7a86d50-fbcd-402f-90f7-36b97ab224ef):
load data inpath
'hdfs://cdncluster/tmp/csv-panda_quality_v1_20160625/part-0.csv' into table
williamtable02
INFO 05-07 16:11:31,587 -
INFO 05-07 16:11:31,587 -
INFO 05-07 16:11:31,587 -
INFO 05-07 16:11:31,588 - Starting task [Stage-0:MOVE] in serial mode
INFO 05-07 16:11:31,589 - Loading data to table default.williamtable02 from
hdfs://cdncluster/tmp/csv-panda_quality_v1_20160625/part-0.csv
INFO 05-07 16:11:31,589 - 0: get_table : db=default tbl=williamtable02
INFO 05-07 16:11:31,589 - ugi=allwefantasy ip=unknown-ip-addr
cmd=get_table : db=default tbl=williamtable02
INFO 05-07 16:11:31,749 - 0: get_table : db=default tbl=williamtable02
INFO 05-07 16:11:31,749 - ugi=allwefantasy ip=unknown-ip-addr
cmd=get_table : db=default tbl=williamtable02
INFO 05-07 16:11:31,942 - Renaming src:
hdfs://cdncluster/tmp/csv-panda_quality_v1_20160625/part-0.csv, dest:
hdfs://cdncluster/user/hive/warehouse/williamtable02/part-0.csv, Status:true
chgrp: changing ownership of
'hdfs://cdncluster/user/hive/warehouse/williamtable02/part-0.csv': User
does not belong to cdnuser
INFO 05-07 16:11:32,009 - 0: alter_table: db=default tbl=williamtable02
newtbl=williamtable02
INFO 05-07 16:11:32,009 - ugi=allwefantasy ip=unknown-ip-addr
cmd=alter_table: db=default tbl=williamtable02 newtbl=williamtable02
INFO 05-07 16:11:32,285 - Updating table stats fast for williamtable02
INFO 05-07 16:11:32,285 - Updated size of table williamtable02 to 389088954
INFO 05-07 16:11:32,425 -
INFO 05-07 16:11:32,426 - Starting task [Stage-1:STATS] in serial mode
INFO 05-07 16:11:32,426 - Executing stats task
INFO 05-07 16:11:32,427 - 0: get_table : db=default tbl=williamtable02
INFO 05-07 16:11:32,427 - ugi=allwefantasy ip=unknown-ip-addr
cmd=get_table : db=default tbl=williamtable02
INFO 05-07 16:11:32,560 - 0: get_table : db=default tbl=williamtable02
INFO 05-07 16:11:32,561 - ugi=allwefantasy ip=unknown-ip-addr
cmd=get_table : db=default tbl=williamtable02
INFO 05-07 16:11:32,706 - 0: alter_table: db=default tbl=williamtable02
newtbl=williamtable02
INFO 05-07 16:11:32,706 - ugi=allwefantasy ip=unknown-ip-addr
cmd=alter_table: db=default tbl=williamtable02 newtbl=williamtable02
INFO 05-07 16:11:32,939 - Updating table stats fast for williamtable02
INFO 05-07 16:11:32,939 - Updated size of table williamtable02 to 389088954
INFO 05-07 16:11:32,984 - Table default.williamtable02 stats: [numFiles=1,
totalSize=389088954]
INFO 05-07 16:11:32,984 -
INFO 05-07 16:11:32,984 -
INFO 05-07 16:11:32,985 - OK
INFO 05-07 16:11:32,985 -
INFO 05-07 16:11:32,985 -
INFO 05-07 16:11:32,985 -
res4: org.apache.spark.sql.SchemaRDD = []
scala> cc.sql("select count(*) from williamtable02").show
INFO 05-07 16:12:10,533 - main Query [SELECT COUNT(*) FROM WILLIAMTABLE02]
INFO 05-07 16:12:10,541 - Parsing command: select count(*) from williamtable02
INFO 05-07 16:12:10,553 - Parse Completed
INFO 05-07 16:12:10,569 - Parsing command: select count(*) from williamtable02
INFO 05-07 16:12:10,570 - Parse Completed
INFO 05-07 16:12:10,619 - 0: get_table : db=default tbl=williamtable02
INFO 05-07 16:12:10,619 - ugi=allwefantasy ip=unknown-ip-addr
cmd=get_table : db=default tbl=williamtable02
INFO 05-07 16:12:10,731 - 0: get_table : db=default