Skip to content

Commit

Permalink
fix scala style
Browse files Browse the repository at this point in the history
  • Loading branch information
AngersZhuuuu committed Aug 8, 2019
1 parent 76c563d commit 5990a54
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -73,8 +73,9 @@ class SparkSessionManager extends Logging {
UserGroupInformation.getLoginUser
}
val delegationToken = getDelegationToken(session.getUserName)
if (delegationToken != null)
if (delegationToken != null) {
Utils.setTokenStr(ugi, delegationToken, STS_TOKEN)
}
ugi
} catch {
case e: IOException =>
Expand Down

0 comments on commit 5990a54

Please sign in to comment.