无法从 AWS EMR 上的 Presto 与 Java JDBC 进行连接/查询

Question

如果我通过 ssh 连接到我的 presto emr 集群的主节点，我可以运行查询。但是，我希望能够在连接到 emr 集群的本地计算机上从 java 源代码运行查询。我使用默认配置设置了我的 presto emr 集群。

我已经尝试过端口转发，但它似乎仍然不起作用。当我创建连接时，我将其打印出来，它是"com.facebook.presto.jdbc.PrestoConnection@XXXXXXX"，但我仍然怀疑它是否真的连接了，因为我无法执行任何查询并且它总是超时。

import java.net.URI;
import java.net.URISyntaxException;
import java.sql.*;
public class PrestoJDBC {
    // JDBC driver name and database URL
    static final String JDBC_DRIVER = "com.facebook.presto.jdbc.PrestoDriver";
    //static final String JDBC_DRIVER = "com.teradata.presto.jdbc42.Driver";
    static final String DB_URL = "jdbc:presto://ec2-XX-XX-XXX-XX.us-east-2.compute.amazonaws.com:8889/hive/default";
    //  Database credentials
    static final String USER = "hadoop";
    static final String PASS = "";
    public static void main(String[] args) throws URISyntaxException {
        Connection conn = null;
        Statement stmt = null;
        try{
            //STEP 2: Register JDBC driver
            Class.forName(JDBC_DRIVER);
            //STEP 3: Open a connection
            //conn = DriverManager.getConnection(DB_URL,USER,PASS);
            conn = DriverManager.getConnection(DB_URL,USER,PASS);
            //STEP 4: Execute a query
            stmt = conn.createStatement();
            System.out.println(conn);
            String sql;
            sql = "select * from onedaytest where readOnly=true;";
            ResultSet rs = stmt.executeQuery(sql);
            //STEP 5: Extract data from result set
            while(rs.next()){
                //Display values
                System.out.println(rs.getString(3));
            }
            //STEP 6: Clean-up environment
            rs.close();
            stmt.close();
            conn.close();
        }catch(SQLException se){
            se.printStackTrace();
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            try{
                if(stmt!=null)
                    stmt.close();
            }catch(SQLException se2){
            }
            try{
                if(conn!=null)
                    conn.close();
            }catch(SQLException se){
                se.printStackTrace();
            }
        }
        System.out.println("Done");
    }
}

我得到一个java.sql.SQLEXception：Error execute query，以及一个java.net.SocketTimeoutException。我想知道是否有任何其他配置或我需要设置才能查询的内容。

Answer 1

这可能是因为防火墙可能不允许您连接到服务器。您必须在主组中创建入站规则。

1. 为此，请先选择您的集群。
2. 在"安全和访问"标题下，单击"主安全组"链接。
3. 现在选择名为"ElasticMapReduce-master"的安全组，然后单击"编辑入站规则"。
在底端，单击"添加规则"，然后在
4. 类型中选择"所有TCP"，然后在源字段中选择"我的ip"或添加要访问的IP地址。
5. 单击保存规则。

再试一次。它会起作用！！