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

Popular posts from this blog

java - UnknownEntityTypeException: Unable to locate persister (Hibernate 5.0) -

python - ValueError: empty vocabulary; perhaps the documents only contain stop words -

ubuntu - collect2: fatal error: ld terminated with signal 9 [Killed] -