diff --git a/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala b/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala index 3f94bd1..0929843 100644 --- a/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala +++ b/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala @@ -64,7 +64,7 @@ class HBaseContext(@transient sc: SparkContext, val tmpHdfsConfgFile: String = null) extends Serializable with Logging { - @transient var credentials = SparkHadoopUtil.get.getCurrentUserCredentials() + @transient var credentials = UserGroupInformation.getCurrentUser().getCredentials() @transient var tmpHdfsConfiguration:Configuration = config @transient var appliedCredentials = false @transient val job = Job.getInstance(config) @@ -232,7 +232,7 @@ class HBaseContext(@transient sc: SparkContext, } def applyCreds[T] (){ - credentials = SparkHadoopUtil.get.getCurrentUserCredentials() + credentials = UserGroupInformation.getCurrentUser().getCredentials() logDebug("appliedCredentials:" + appliedCredentials + ",credentials:" + credentials)