hive-site.xml中的以下属性是否适用于对cassandra的配置单元访问??
(我复制了整个hive-default.xml内容,但只更改了以下属性)
javax.jdo.option.ConnectionURL : cassandra://localhost:9160
javax.jdo.option.ConnectionDriverName:org.apache.cassandra.cql.jdbc.CassandraDriver
hive.stats.dbclass: jdbc:cassandra
hive.stats.jdbcdriver: org.apache.cassandra.cql.jdbc.CassandraDriver
hive.stats.dbconnectionstring: jdbc:cassandra:;databaseName=TempStatsStore;create=true
我正在运行单节点cassandra。但是,后来会使它成为一个最小的2节点集群。
运行下表创建命令时出现错误:
CREATE EXTERNAL TABLE MyHiveTable
(m string, n string, o string, p string)
STORED BY 'org.apache.hadoop.hive.cassandra.cql3.CqlStorageHandler'
TBLPROPERTIES ( "cassandra.ks.name" = "cql3ks",
"cassandra.cf.name" = "test",
"cassandra.cql3.type" = "text, text, text, text");
错误:
FAILED: Error in metadata: javax.jdo.JDOFatalInternalException: Error creating transactional connection factory
NestedThrowables:
java.lang.reflect.InvocationTargetException
FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask
1条答案
按热度按时间edqdpe6u1#
不知道jdo的设置,但你可以试试这个链接,它是集成hive和cassandra的更好的选择-https://github.com/milliondreams/hive/tree/cas-support-cql/cassandra-handler