Skip to content

Commit

Permalink
Update externals/kyuubi-hive-sql-engine/src/main/scala/org/apache/kyu…
Browse files Browse the repository at this point in the history
…ubi/engine/hive/HiveTBinaryFrontendService.scala
  • Loading branch information
pan3793 authored Nov 27, 2023
1 parent 9f6c452 commit d0e7917
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,8 +66,8 @@ object HiveTBinaryFrontendService {
// HiveMetastoreClient authentication.
if (currentUser.getAuthenticationMethod == UserGroupInformation.AuthenticationMethod.PROXY) {
val newCreds = KyuubiHadoopUtils.decodeCredentials(tokenStr)
KyuubiHadoopUtils.getTokenMap(newCreds).values.find(_.getKind == new Text(
"HIVE_DELEGATION_TOKEN"))
KyuubiHadoopUtils.getTokenMap(newCreds).values
.find(_.getKind == new Text("HIVE_DELEGATION_TOKEN"))
.foreach { token =>
UserGroupInformation.getCurrentUser.addToken(token)
}
Expand Down

0 comments on commit d0e7917

Please sign in to comment.