Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-20375 Remove use of getCurrentUserCredentials in hbase-spark module

This commit is contained in:
tedyu 2018-04-11 11:59:10 -07:00
parent 1ad09d2f66
commit 3342383850
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseContext.scala
View File

@ -65,7 +65,7 @@ class HBaseContext(@transient val 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)
@ -233,9 +233,11 @@ class HBaseContext(@transient val sc: SparkContext,
}
def applyCreds[T] (){
credentials = SparkHadoopUtil.get.getCurrentUserCredentials()
credentials = UserGroupInformation.getCurrentUser().getCredentials()
logDebug("appliedCredentials:" + appliedCredentials + ",credentials:" + credentials)
if (log.isDebugEnabled) {
logDebug("appliedCredentials:" + appliedCredentials + ",credentials:" + credentials)
}
if (!appliedCredentials && credentials != null) {
appliedCredentials = true