在 Hortonworks Sandbox 2.0 中无法通过 JDBC 访问 Hive 表答案

【问题标题】：Not able to access Hive Tables through JDBC in Hortonworks Sandbox 2.0在 Hortonworks Sandbox 2.0 中无法通过 JDBC 访问 Hive 表
【发布时间】：2014-03-13 16:25:06
【问题描述】：

我正在使用 Hortonworks Sandbox 2.0。我在 Eclipse IDE 中尝试了以下程序，但不是访问我的 Hive 表的表。得到以下错误。我该怎么做才能解决这个问题？

我也使用了这个：hive –service hiveserver，然后无法连接。我正在使用 VMware。

    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.hadoop.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);
    }
    Connection con = DriverManager.getConnection(“jdbc:hive://localhost:10000/default”, “”, “”);
    Statement stmt = con.createStatement();
    String tableName = “testHiveDriverTable”;
    stmt.executeQuery(“drop table ” + tableName);
    ResultSet res = stmt.executeQuery(“create table ” + tableName + ” (key int, value string)”);
    // show tables
    String sql = “show tables ‘” + tableName + “‘”;
    System.out.println(“Running: ” + sql);
    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);
    res = stmt.executeQuery(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));
    }
    }
    }

—— 出错了

Exception in thread “main” java.sql.SQLException: Could not establish connection to 172.31.153.71:10000/default: java.net.ConnectException: Connection refused: connect
at org.apache.hadoop.hive.jdbc.HiveConnection.<init>(HiveConnection.java:117)
at org.apache.hadoop.hive.jdbc.HiveDriver.connect(HiveDriver.java:106)
at java.sql.DriverManager.getConnection(DriverManager.java:582)
at java.sql.DriverManager.getConnection(DriverManager.java:185)
at com.coe.convert.hive.temp.htw.HiveJdbcClient.main(HiveJdbcClient.java:28)

【问题讨论】：

您是在沙箱中还是在您的主机上运行此程序？如果在您的主机上运行，您需要使用沙盒 IP 地址
1) 我从我的 Eclipse 工作，它不工作。 2）我也在 vmware 沙箱中作为 jar 运行 - 也没有连接。它挂了...无法获取系统。我给出了 etc/hosts 文件中提到的 ip。如何从 sadbox 内部和外部进行连接。3）在使用加载 hortonwork imgae 的 vmware（vsphere 服务器）进行连接时遇到很多问题。需要建议。
我提到了我的 vsphere 客户端地址

标签： hadoop jdbc hive sandbox hortonworks-data-platform

【解决方案1】：

在另一个端口上运行 hive。然后使用新的端口号就可以了。使用以下命令将端口号 10000 更改为 10001。

hive --service hiveserver -p 10001

然后使用，

172.31.153.71:10000/default

【讨论】：