hadoop - cassandra 需要 javax.jdo.option.ConnectionURL

Question

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

Answer 1

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