1
CREATE EXTERNAL TABLE IF NOT EXISTS
message (key string, loc string, machineid string, message string, msgdate string, quantity int, time string)
STORED BY 'org.apache.hadoop.hive.cassandra.CassandraStorageHandler'WITH SERDEPROPERTIES
 ("cassandra.columns.mapping" = ":key,smslog,:location,:machineid,:message,:msgdate,:quantity,:time", "cassandra.cf.name" = "smslog", 
"cassandra.host" = "127.0.0.1" , "cassandra.port" = "9160",
"cassandra.partitioner" = "org.apache.cassandra.dht.
RandomPartitioner" )
TBLPROPERTIES ("cassandra.ks.name" = "SMSLogs");

失败并出现异常 org.apache.hadoop.hive.ql.metadata.HiveException:加载存储处理程序时出错。org.apache.hadoop.hive.cassandra.CassandraStorageHandler 失败:执行错误,从 org.apache.hadoop.hive 返回代码 1 .ql.exec.DDLTask

4

0 回答 0