必需字段’client_protocol’未设置

我正在使用Hive 0.12，我正在尝试从apache中获取JDBC。 当我尝试运行代码时，我得到apache.thrift.TApplicationException。

import java.sql.SQLException; import java.sql.Connection; import java.sql.ResultSet; import java.sql.Statement; import java.sql.DriverManager; public class HiveJdbcClient { private static String driverName = "org.apache.hive.jdbc.HiveDriver"; /** * @param args * @throws SQLException */ public static void main(String[] args) throws SQLException { try { Class.forName(driverName); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); System.exit(1); } //replace "hive" here with the name of the user the queries should run as Connection con = DriverManager.getConnection("jdbc:hive2://localhost:10000/default", "hive", ""); Statement stmt = con.createStatement(); String tableName = "testHiveDriverTable"; stmt.execute("drop table if exists " + tableName); stmt.execute("create table " + tableName + " (key int, value string)"); // show tables String sql = "show tables '" + tableName + "'"; System.out.println("Running: " + sql); ResultSet res = stmt.executeQuery(sql); if (res.next()) { System.out.println(res.getString(1)); } // describe table sql = "describe " + tableName; System.out.println("Running: " + sql); res = stmt.executeQuery(sql); while (res.next()) { System.out.println(res.getString(1) + "\t" + res.getString(2)); } // load data into table // NOTE: filepath has to be local to the hive server // NOTE: /tmp/a.txt is a ctrl-A separated file with two fields per line String filepath = "/tmp/a.txt"; sql = "load data local inpath '" + filepath + "' into table " + tableName; System.out.println("Running: " + sql); stmt.execute(sql); // select * query sql = "select * from " + tableName; System.out.println("Running: " + sql); res = stmt.executeQuery(sql); while (res.next()) { System.out.println(String.valueOf(res.getInt(1)) + "\t" + res.getString(2)); } // regular hive query sql = "select count(1) from " + tableName; System.out.println("Running: " + sql); res = stmt.executeQuery(sql); while (res.next()) { System.out.println(res.getString(1)); } } 

}

我导入了所有必需的jar，当我尝试运行我的代码时，我收到以下错误：

  org.apache.thrift.TApplicationException: Required field 'client_protocol' is unset! Struct:TOpenSessionReq(client_protocol:null) 

我怎样才能解决这个问题？

Answer 1

这表示客户端和服务器之间的版本不匹配，即客户端比服务器更新，这是您的情况。

Answer 2

有同样的问题。 它可以设置

hive JDBC Maven Repo版本为1.1.0。

检查这个jira。 HIve 0.13不支持最新的hive-jdbc版本。 https://issues.apache.org/jira/browse/HIVE-6050

在你的pom中添加它。

  org.apache.hive hive-jdbc 1.1.0 standalone  

Answer 3

伙计们即使我遇到同样的问题，也可以通过以下步骤来解决问题

步骤01： – 使用以下链接在您的eclipse（可能是IDE）上包含Hive lib jar。

http://mirrors.supportex.net/apache/hive/hive-1.0.1/(apache-hive- 1.0.1-bin.tar.gz）

步骤02：添加hadoop-core-1.1.0 jar

因为每个人都提到这个错误是由于版本与hadoop独立和hadoop核心不匹配而发生的。