Github user jerryshao commented on a diff in the pull request:
https://github.com/apache/spark/pull/21396#discussion_r190112524
--- Diff:
core/src/main/scala/org/apache/spark/deploy/security/HiveDelegationTokenProvider.scala
---
@@ -85,7 +85,10 @@ private[spark] class HiveDelegationTokenProvider
val principal = conf.getTrimmed(principalKey, "")
require(principal.nonEmpty, s"Hive principal $principalKey
undefined")
val metastoreUri = conf.getTrimmed("hive.metastore.uris", "")
- require(metastoreUri.nonEmpty, "Hive metastore uri undefined")
+ if (metastoreUri.isEmpty) {
--- End diff --
Before getting the DT, we will check if `delegationTokensRequired` returns
true or false, if it is false, then we will not get DT. Here since
"hive.metastore.uris" is not configured, then it should return false.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
