File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
yarn/src/main/scala/org/apache/spark/scheduler/cluster Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -24,7 +24,6 @@ import org.apache.hadoop.yarn.api.records.YarnApplicationState
2424import org .apache .spark .{SparkContext , SparkException }
2525import org .apache .spark .deploy .yarn .{Client , ClientArguments , YarnSparkHadoopUtil }
2626import org .apache .spark .internal .Logging
27- import org .apache .spark .internal .config .PRINCIPAL
2827import org .apache .spark .launcher .SparkAppHandle
2928import org .apache .spark .scheduler .TaskSchedulerImpl
3029
@@ -65,7 +64,7 @@ private[spark] class YarnClientSchedulerBackend(
6564 // SPARK-8851: In yarn-client mode, the AM still does the credentials refresh. The driver
6665 // reads the credentials from HDFS, just like the executors and updates its own credentials
6766 // cache.
68- if (! conf.contains( PRINCIPAL .key) && conf.contains(" spark.yarn.credentials.file" )) {
67+ if (conf.contains(" spark.yarn.credentials.file" )) {
6968 YarnSparkHadoopUtil .get.startExecutorDelegationTokenRenewer(conf)
7069 }
7170 monitorThread = asyncMonitorApplication()
You can’t perform that action at this time.
0 commit comments