hadoop - Connecting Cassandra with Hive -
currently using cassandra 2.1.5, hive 1.2.1 , hadoop 2.7.1. try connect cassandra hive using tutorial :
http://frommyworkshop.blogspot.com/2013/09/real-time-data-processing-with.html
but seems got stuck in create external table:
create external table test.pokes(foo int, bar string) stored 'org.apache.hadoop.hive.cassandra.cassandrastoragehandler' serdeproperties ("cassandra.host" = "127.0.0.1" , "cassandra.port" = "9160", "cql.primarykey" = "foo", "comment"="check", "read_repair_chance" = "0.2", "dclocal_read_repair_chance" = "0.14", "gc_grace_seconds" = "989898", "bloom_filter_fp_chance" = "0.2", "compaction" = "{'class' : 'leveledcompactionstrategy'}", "replicate_on_write" = "false", "caching" = "all");
with error this:
failed: execution error, return code 1 org.apache.hadoop.hive.ql.exec.ddltask. 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;
does know how fix this?
fixing hive-cassandra store handler issue tedious.
the error log spot on shell might not helpful always.
please refer hive log file , located in /tmp/<user-id>/hive.log
, actual detailed error message regarding failure.
mostly reasons because of wrong cassandra hostname/port, keyspace, key conf, etc.
hope helps.
Comments
Post a Comment