Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19631#discussion_r150916635
--- Diff:
core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala
---
@@ -216,7 +216,9 @@ private[spark] object CoarseGrainedExecutorBackend
extends Logging {
if (driverConf.contains("spark.yarn.credentials.file")) {
logInfo("Will periodically update credentials from: " +
driverConf.get("spark.yarn.credentials.file"))
- SparkHadoopUtil.get.startCredentialUpdater(driverConf)
+
Utils.classForName("org.apache.spark.deploy.yarn.YarnSparkHadoopUtil")
--- End diff --
`YarnSparkHadoopUtil` does not extend `SparkHadoopUtil` anymore (it doesn't
even exist as a class), so I'm using this to invoke the method on the YARN
object.
I plan to clean this up once #19272 is in, since that's a cleaner way to do
this token renewal thing.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
