1

我有一个 Hive 客户端（用 Java 编写），它与 FIWARE Lab 的 Global Instance of Cosmos 配合得很好。但是，它不再工作了，客户端似乎无法连接（超时）。

服务器端有什么变化吗？

4

1 回答 1

4

这是因为 FIWARE Lab 的 Cosmos 全局实例已经升级，现在 HiveServer2 正在 Hive 的服务器端运行。因此，您的代码中的所有内容仍然有效，但以下内容除外：

  • 加载org.apache.hive.jdbc.HiveDriver而不是org.apache.hadoop.hive.jdbc.HiveDriver.
  • 将 JDBC 连接模式从更改jdbc:hive为jdbc:hive2
  • 将 Hive 依赖项更改为 0.13.0 版本。

我的意思是，代码最终应该具有以下方面：

try {
    // dynamically load the Hive JDBC driver
    Class.forName("org.apache.hive.jdbc.HiveDriver");
} catch (ClassNotFoundException e) {
    System.out.println(e.getMessage());
    return null;
} // try catch

try {
    // return a connection based on the Hive JDBC driver
    return DriverManager.getConnection("jdbc:hive2://" + hiveServer + ":" + hivePort,
            hadoopUser, hadoopPassword);
} catch (SQLException e) {
    System.out.println(e.getMessage());
    return null;
} // try catch

关于依赖项，如果使用例如 Maven，您pom.xml应该包含以下内容：

...
<dependencies>
  ...
  <dependency>
    <groupId>org.apache.hive</groupId>
    <artifactId>hive-exec</artifactId>
    <version>0.13.0</version>
  </dependency>
  <dependency>
    <groupId>org.apache.hive</groupId>
    <artifactId>hive-jdbc</artifactId>
    <version>0.13.0</version>
  </dependency>
  ...
</dependencies>
...

最后，如果使用类似 JSON 的格式，则需要添加 JSON serde。在 Hive CLI 中，这非常简单：

hive> add JAR /usr/local/apache-hive-0.13.0-bin/lib/json-serde-1.3.1-SNAPSHOT-jar-with-dependencies.jar;

从您的 Hive 客户端，只需使用上述命令执行更新语句。

于 2015-08-21T07:16:21.687 回答