replace hive with generic method

This commit is contained in:
Prabhjyot Singh 2017-04-28 16:53:41 +05:30
parent a348e969a3
commit 9fee9d2a9e

View file

@ -362,7 +362,7 @@ public class JDBCInterpreter extends Interpreter {
property.getProperty("zeppelin.jdbc.auth.kerberos.proxy.enable"))) {
connection = getConnectionFromPool(connectionUrl, user, propertyKey, properties);
} else {
if (url.trim().startsWith("jdbc:hive")) {
if (basePropretiesMap.get(propertyKey).containsKey("proxy.user.property")) {
connection = getConnectionFromPool(connectionUrl, user, propertyKey, properties);
} else {
UserGroupInformation ugi = null;