连接cassandra和hive

p3rjfoxz  于 2021-06-03  发布在  Hadoop
关注(0)|答案(2)|浏览(381)

目前我正在使用Cassandra2.1.5、Hive1.2.1和Hadoop2.7.1。我尝试使用以下教程将cassandra连接到hive:
http://frommyworkshop.blogspot.com/2013/09/real-time-data-processing-with.html
但我似乎被困在了创建外部表中:
使用serdeproperties(“cassandra.host”=“127.0.0.1”,“cassandra.port”=“9160”,“cql.primarykey”=“foo”,“comment”=“check”,“read\u repair\u chance”=“0.2”,“dclocal\u read\u repair\u chance”=“0.14”,“gc\u grace\u seconds”=“9898”,“bloom\u filter\u fp\u chance”=“0.2”,“compression”=“class”:“leveledcompactionstrategy”},“replicate\u on\u write”=“false”,“caching”=“all”);
错误如下:
失败:执行错误,从org.apache.hadoop.hive.ql.exec.ddltask返回代码1。org.apache.hadoop.hive.serde2.lazy.lazysimpleserde.initserdeparams(lorg/apache/hadoop/conf/configuration;ljava/util/properties;ljava/lang/string;)lorg/apache/hadoop/hive/serde2/lazy/lazysimpleserde$serdeparameters;
有人知道怎么解决这个问题吗?

vhmi4jdf

vhmi4jdf1#

修复这个hive cassandra存储处理程序问题可能会很乏味。
您在shell上发现的错误日志可能并不总是有用的。
请参阅配置单元日志文件,该文件主要位于 /tmp/<user-id>/hive.log ,以获取有关失败的实际详细错误消息。
主要原因可能是cassandra的hostname/port、keyspace、key conf等错误。
希望这有帮助。

piv4azn7

piv4azn72#

2013年博客上关于Hive和Cassandra的信息已经过时了。例如,“org.apache.hadoop.hive.cassandra.cassandrastoragehandler”不久前被“org.apache.hadoop.hive.cassandra.cql3.cqlstoragehandler”替换。我认为您需要使用dse配置byoh。

相关问题