From 60e2de212ee5a545e0c21d947841dc89d7199f49 Mon Sep 17 00:00:00 2001 From: galarragas Date: Wed, 3 Sep 2014 10:40:13 +0100 Subject: Adding support for Kerberos Authentication --- src/main/scala/parallelai/spyglass/base/JobRunner.scala | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) (limited to 'src/main/scala/parallelai') diff --git a/src/main/scala/parallelai/spyglass/base/JobRunner.scala b/src/main/scala/parallelai/spyglass/base/JobRunner.scala index b3a9af0..632a345 100644 --- a/src/main/scala/parallelai/spyglass/base/JobRunner.scala +++ b/src/main/scala/parallelai/spyglass/base/JobRunner.scala @@ -3,7 +3,10 @@ package parallelai.spyglass.base import org.apache.hadoop.conf.Configuration import com.twitter.scalding.Tool import org.apache.hadoop - +import org.apache.hadoop.hbase.security.token.TokenUtil +import org.apache.hadoop.security.UserGroupInformation +import org.apache.hadoop.hbase.security.User + object JobRunner { def main(args : Array[String]) { val conf: Configuration = new Configuration @@ -17,6 +20,11 @@ object JobRunner { } AppConfig.jobConfig = conf + + if (User.isHBaseSecurityEnabled(conf)) { + println("Obtaining token for HBase security."); + TokenUtil.obtainAndCacheToken(conf, UserGroupInformation.getCurrentUser()); + } hadoop.util.ToolRunner.run(conf, new Tool, args); } -- cgit v1.2.3