Подключение к удаленному Mapr Hive через JDBC

У меня тоже была такая же проблема. Пожалуйста, проверьте, доступен ли сервер через порт 10000 от клиента (сервер и порт включены, брандмауэр не ограничивает), а также проверьте, что hiveserver запущен и работает. если да, то он должен работать. следующий код работает для меня для улья mapr.

Если у вас есть какой-либо mapr, связанный с запросами, обратитесь на answers.mapr.com, он содержит большую часть информации, которая может вам понадобиться.

import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.DriverManager;
import org.apache.log4j.Logger;


import java.io.*;
import org.apache.hadoop.io.SequenceFile;
import org.apache.hadoop.io.SequenceFile.*;
import org.apache.hadoop.io.SequenceFile.Writer;
import org.apache.hadoop.io.*;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.io.Writable;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.conf.*;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.*;

public class HiveJdbcClient {
    //private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";
    /**
    * @param args
    * @throws SQLException
    **/
    private static Logger mLogger = Logger.getLogger(HiveJdbcClient.class);
    private static String driverName = "org.apache.hadoop.hive.jdbc.HiveDriver";

    public static void main(String[] args) throws SQLException {
        HiveJdbcClient myJob = new HiveJdbcClient();
        myJob.execute();
    }
    public void execute() throws SQLException {
        //mLogger.info("Start HiveJob");
        System.out.println("Start HiveJob");
        try {
            Class.forName(driverName);
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            System.exit(1);
        }
Connection con = DriverManager.getConnection("jdbc:hive://myserver:10000/default", "", "");
        Statement stmt = con.createStatement();
        String sql = "SHOW TABLES";
        //String tableName = "testHiveDriverTable";
       // ResultSet res1 = stmt.executeQuery("create table " + tableName + " (key int, value string)");
        System.out.println("Running: " + sql);
        ResultSet res = stmt.executeQuery(sql);
        while (res.next()) {
            System.out.println(res.getString(1));
        }

        //mLogger.info("HiveJob executed!");
        System.out.println("HiveJob executed!");
    }
}

Вы можете использовать клиент beeline для подключения к улью с помощью JDBC.

Это будет что-то вроде: beeline! Connect jdbc: hive2: // localhost: 10000

проверьте ссылку: http://dwbitechguru.blogspot.ca/2014/11/how-to-connect-to-hadoop-hive-using.html.

В моем случае добавление: ;auth=noSasl в строку подключения JDBC решило бесконечное ожидание подключения!

jdbc:hive2://server:10000/default;auth=noSasl

Здесь вы должны получить hive-service-X.XX.X-cdhX.XXjar: https://repository.cloudera.com/artifactory/cloudera-repos/org/apache/hive/; У меня все работает нормально.