1

hive-site.xml 中的以下属性对于 Hive 访问 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

我正在运行 1 节点 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
4

1 回答 1

0

不了解 jdo 设置，但您可以尝试此链接，这是将 hive 与 cassandra 集成的更好选择 - https://github.com/milliondreams/hive/tree/cas-support-cql/cassandra-handler

于 2013-12-29T08:27:18.920 回答