From c9f3f96312ad569d5c53a39c3b5d936c60309187 Mon Sep 17 00:00:00 2001 From: kkuramot Date: Fri, 14 Jul 2017 16:24:55 +0900 Subject: [PATCH] KYLIN-2683 Support reloading kerberos token of BeelineHiveClient --- .../src/main/java/org/apache/kylin/source/hive/BeelineHiveClient.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/source-hive/src/main/java/org/apache/kylin/source/hive/BeelineHiveClient.java b/source-hive/src/main/java/org/apache/kylin/source/hive/BeelineHiveClient.java index ee693c5..5e4e13e 100644 --- a/source-hive/src/main/java/org/apache/kylin/source/hive/BeelineHiveClient.java +++ b/source-hive/src/main/java/org/apache/kylin/source/hive/BeelineHiveClient.java @@ -29,6 +29,7 @@ import java.util.List; import org.apache.commons.lang3.StringUtils; import org.apache.hadoop.hive.ql.CommandNeedRetryException; +import org.apache.hadoop.security.UserGroupInformation; import org.apache.kylin.common.util.DBUtils; import com.google.common.base.Preconditions; @@ -62,11 +63,12 @@ public class BeelineHiveClient implements IHiveClient { private void init(String url, String username, String password) { try { + UserGroupInformation.loginUserFromSubject(null); Class.forName("org.apache.hive.jdbc.HiveDriver"); cnct = DriverManager.getConnection(url, username, password); stmt = cnct.createStatement(); metaData = cnct.getMetaData(); - } catch (SQLException | ClassNotFoundException e) { + } catch (SQLException | ClassNotFoundException | IOException e) { throw new RuntimeException(e); } } -- 1.8.3.1