aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/scala/parallelai/spyglass/base
diff options
context:
space:
mode:
authorgalarragas <galarragas@gmail.com>2014-09-03 11:22:21 +0100
committergalarragas <galarragas@gmail.com>2014-09-03 11:22:21 +0100
commitd26a8f98f9800549c25cb454a5a57cfe4a45926d (patch)
tree82d88473191d051a24a9ec58e121206da773dccb /src/main/scala/parallelai/spyglass/base
parent28268878f992923f27892d89c09ddf34767a9092 (diff)
downloadSpyGlass-d26a8f98f9800549c25cb454a5a57cfe4a45926d.tar.gz
SpyGlass-d26a8f98f9800549c25cb454a5a57cfe4a45926d.zip
Changed version number to prepare for release and added kerberos authentication support to JobRunner4.4
Diffstat (limited to 'src/main/scala/parallelai/spyglass/base')
-rw-r--r--src/main/scala/parallelai/spyglass/base/JobRunner.scala12
1 files changed, 10 insertions, 2 deletions
diff --git a/src/main/scala/parallelai/spyglass/base/JobRunner.scala b/src/main/scala/parallelai/spyglass/base/JobRunner.scala
index b3a9af0..3069051 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,7 +20,12 @@ 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);
}
} \ No newline at end of file