Skip to content

Commit bb469c7

Browse files
committed
fix
1 parent b902a29 commit bb469c7

1 file changed

Lines changed: 5 additions & 6 deletions

File tree

  • extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/ranger

extensions/spark/kyuubi-spark-authz/src/main/scala/org/apache/kyuubi/plugin/spark/authz/ranger/AccessRequest.scala

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -145,12 +145,11 @@ object AccessRequest extends Logging {
145145

146146
private def getUserGroupsFromUserStore(user: UserGroupInformation): Option[JSet[String]] = {
147147
(getUserStoreEnricherMethod, getRangerUserStoreMethod, getUserGroupMappingMethod) match {
148-
case (Some(getEnricher), Some(getUserStore), Some(getMapping)) => Try {
149-
val enricher = getEnricher.invoke()
150-
val userStore = getUserStore.bind(enricher).invoke()
151-
val userGroupMapping: JHashMap[String, JSet[String]] = getMapping.bind(userStore).invoke()
152-
userGroupMapping.get(user.getShortUserName)
153-
}.toOption
148+
case (Some(getEnricher), Some(getUserStore), Some(getMapping)) =>
149+
val enricher = getEnricher.invoke()
150+
val userStore = getUserStore.bind(enricher).invoke()
151+
val userGroupMapping: JHashMap[String, JSet[String]] = getMapping.bind(userStore).invoke()
152+
Some(userGroupMapping.get(user.getShortUserName))
154153
case _ => None
155154
}
156155
}

0 commit comments

Comments
 (0)