使用Java代码通过JDBC连接只启用Sentry的Impala异常分析

Fayson

修改于 2018-04-01 21:00:57

1.6K0

修改于 2018-04-01 21:00:57

文章被收录于专栏：Hadoop实操 Hadoop实操Hadoop实操

温馨提示：要看高清无码套图，请使用手机打开并单击图片放大查看。 Fayson的github：https://github.com/fayson/cdhproject 提示：代码块部分可以左右滑动查看噢

1.问题描述

测试环境描述：

CM和CDH版本为5.13.1
集群只启用了Sentry
Impala JDBC2.5.42

在使用Java代码访问只启用了Sentry的Impala集群，即集群未启用认证比如LDAP或者Kerberos，会出现获取JDBC连接hang死的现象，具体示例代码如下：

public class SentryOnlyDemo {
    private static String JDBC_DRIVER = "com.cloudera.impala.jdbc4.Driver";
    private static String CONNECTION_URL ="jdbc:impala://13.229.116.237:21050/default;AuthMech=2;UID=hive;UseSasl=0";
    static {
        try {
            Class.forName(JDBC_DRIVER);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public static void main(String[] args) {
        System.out.println("集群中只启用了Sentry服务通过JDBC访问Impala");
        Connection connection = null;
        ResultSet rs = null;
        PreparedStatement ps = null;
        try {
            connection = DriverManager.getConnection(CONNECTION_URL);
            ps = connection.prepareStatement("show databases");
            rs = ps.executeQuery();
            while (rs.next()) {
                System.out.println(rs.getString(1));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.disconnect(connection, rs, ps);
        }
    }
}

（可左右滑动）

在JDBC连接的URL中指定了AuthMech=2;UID=hive参数后在获取Connection时一直hang住无法正常获取JDBC连接。

2.解决方法

1.将Impala驱动Cloudera_ImpalaJDBC41，并加上参数PWD为空，修改JDBC URL连接为如下：

private static String JDBC_DRIVER = "com.cloudera.impala.jdbc41.Driver";
private static String CONNECTION_URL =" jdbc:impala://13.229.116.237:21050/default;AuthMech=3;UID=hive;PWD=;UseSasl=0";

（可左右滑动）

2.运行示例代码执行如下