我正在尝试使用JDBC连接连接到impala。使用的Imapala驱动程序jar是impalaJDBC41。创建连接对象'con‘时出错,错误是在Imapala jdbc连接中设置/关闭会话时出现-SimbaImpalaJDBCDriver错误
代码如下:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class JDBC_Connection1 {
private static String driverName = "com.cloudera.impala.jdbc41.Driver";
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:impala://host:25004/;principal=impala/host@abc.ENTERPRISENET.ORG");
Statement stmt = con.createStatement();
String tableName = "yogesh";
stmt.executeQuery("drop table " + tableName);
}
}
发布于 2017-11-01 12:58:06
网址应为: jdbc:impala://192.168.8.183:21050;AuthMech=1;KrbRealm=abc.ENTERPRISENET.ORG;KrbHostFQDN=your-host;KrbServiceName=impala
kerberos需要hadoop kerberos环境
System.setProperty("sun.security.krb5.debug", "false");
System.setProperty("java.security.krb5.conf",loader.getResource("secret/krb5.ini").getPath());
org.apache.hadoop.conf.Configuration conf = new org.apache.hadoop.conf.Configuration();
conf.set("hadoop.security.authentication", "Kerberos");
UserGroupInformation.setConfiguration(conf);
UserGroupInformation.loginUserFromKeytab("hdfs/admin@HADOOP.COM", loader.getResource("secret/184_hdfs.keytab").getPath());
UserGroupInformation loginUser = UserGroupInformation.getLoginUser();
loginUser.doAs(new PrivilegedAction<Void>() {
@Override
public Void run() {
connectImpala();
return null;
}
});
}
发布于 2017-12-06 03:52:14
我在Cloudera JDBC driver for Hive中遇到了同样的错误(代码500151),并且能够通过将;SocketTimeout=0
添加到我的连接字符串来解决这个问题。
请务必阅读文档,以确保您没有忘记一些属性:
https://stackoverflow.com/questions/36741638
复制相似问题