我的 Hive 客户端停止使用 Cosmos 实例

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

服务器端有什么变化吗？

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

• Load org.apache.hive.jdbc.HiveDriver代替org.apache.hadoop.hive.jdbc.HiveDriver.
• 更改 JDBC 连接架构jdbc:hive to 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 客户端，只需使用上述命令执行更新语句即可。