必填字段'client_protocol'未设置 [英] Required field 'client_protocol' is unset

问题描述

我使用的是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; 
 $ b $ ** 
 * @param args 
 * @throws SQLException 
 * / 
 public static void main（String [] args）throws SQLException { 
尝试{
 Class.forName（driverName）; 
} catch（ClassNotFoundException e）{
 // TODO自动生成的catch块
 e.printStackTrace（）; 
 System.exit（1）; 
} 
 //将hive替换为用户的名字查询应该以
的形式运行Connection con = DriverManager.getConnection（jdbc：hive2：// localhost：10000 / default ，蜂房，）; 
 Statement stmt = con.createStatement（）; 
 String tableName =testHiveDriverTable; 
 stmt.execute（drop drop if exists+ tableName）; 
 stmt.execute（create table+ tableName +（key int，value string））; 
 //显示表格
字符串sql =显示表格+ tableName +'; 
 System.out.println（Running：+ sql）; 
 ResultSet res = stmt.executeQuery（sql）; 
 if（res.next（））{
 System.out.println（res.getString（1））; 
} 
 //描述表
 sql =describe+ tableName; 
 System.out.println（Running：+ sql）; 
 res = stmt.executeQuery（sql）; （res.next（））{
 System.out.println（res.getString（1）+\ t+ res.getString（2））; 
} 
 
 //将数据加载到表中
 //注意：文件路径必须是hive服务器的本地
 //注意：/tmp/a.txt是一个ctrl-A分隔文件，每行有两个字段
 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）; $（）res.get（）（）; $（
 while（res.next（））{
 System.out.println（String.valueOf（res.getInt（1））+\t+ res.getString（2））; 
} 
 
 //常规蜂巢查询
 sql =select count（1）from+ tableName; 
 System.out.println（Running：+ sql）; 
 res = stmt.executeQuery（sql）; $（res.next（））{
 System.out.println（res.getString（1））; 
} 
} 
  

}

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

  org.apache.thrift.TApplicationException：必填字段'client_protocol'未设置！ Struct：TOpenSessionReq（client_protocol：null）
  

如何解决这个问题？这意味着客户端和服务器之间的版本不匹配，即客户端比服务器更新，这是您的情况。

$ b $

b

I am using Hive 0.12, and I'm trying the JDBC from apache. When I try to run the code, I get 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));
    }
}

}

I imported all the necessary jars, and when I try to run my code, I get the following error:

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

How can I fix this?

解决方案

This indicates a version mismatch between client and server, namely that the client is newer than the server, which is your case.

这篇关于必填字段'client_protocol'未设置的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！