使用presto jdbc驱动程序在配置单元中查询表-失败,出现“服务器拒绝连接”错误

ubby3x7f  于 2021-06-28  发布在  Hive
关注(0)|答案(1)|浏览(410)

我正在使用presto查询emr中的配置单元表。我初始化了presto驱动程序并获取连接,但是当我尝试对该连接执行查询时,我得到一个错误:服务器拒绝连接:http://aws.address/v1/statement.
使用之前是否需要设置配置单元/aws凭据?我该怎么做?

public void init() {
    try {
        Class.forName("com.facebook.presto.jdbc.PrestoDriver");
        if(connection == null)
            connection = DriverManager.getConnection(url,username,password);
            // url = "jdbc:presto://aws.address:8889/hive/default"
        } catch (ClassNotFoundException | SQLException e) {
            // TOD: handle exception
            e.printStackTrace();
        }
    }

public void executeMyQuery() {
    if(connection == null) {
        connection = driver.getConnection();
    }

    ResultSet resultSet = null;
    Statement stmt = connection.createStatement();

    try {
        resultSet = stmt.executeQuery(query);

    } catch (Exception e) {
        logger.error("Failed to execute query, with error: ",e);
    } finally {
        if(resultSet != null) {
            try {
                resultSet.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if(stmt != null){
            stmt.close();
        }
    }
}
d8tt03nd

d8tt03nd1#

我需要使用“端口转发”命令(ssh)来访问aws中的presto驱动程序。

相关问题