gaborgsomogyi commented on a change in pull request #23499: [SPARK-26254][CORE]
Extract Hive + Kafka dependencies from Core.
URL: https://github.com/apache/spark/pull/23499#discussion_r249406329
##########
File path:
core/src/main/scala/org/apache/spark/deploy/security/HadoopDelegationTokenProvider.scala
##########
@@ -43,11 +44,13 @@ private[spark] trait HadoopDelegationTokenProvider {
* Obtain delegation tokens for this service and get the time of the next
renewal.
* @param hadoopConf Configuration of current Hadoop Compatible system.
* @param creds Credentials to add tokens and security keys to.
+ * @param fileSystems List of file systems for which to obtain delegation
tokens.
* @return If the returned tokens are renewable and can be renewed, return
the time of the next
* renewal, otherwise None should be returned.
*/
def obtainDelegationTokens(
hadoopConf: Configuration,
sparkConf: SparkConf,
+ fileSystems: Set[FileSystem],
Review comment:
Felt the same when changed but didn't have good solution. Good suggestion,
will file a jira and resolve it.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
