File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
core/src/main/scala/org/apache/spark/deploy
yarn/src/main/scala/org/apache/spark/deploy/yarn Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -297,7 +297,7 @@ class SparkHadoopUtil extends Logging {
297297 * Start a thread to periodically update the current user's credentials with new delegation
298298 * tokens so that writes to HDFS do not fail.
299299 */
300- private [spark] def startExecutorDelegationTokenRenewer (conf : SparkConf ){}
300+ private [spark] def startExecutorDelegationTokenRenewer (conf : SparkConf ) {}
301301
302302 /**
303303 * Stop the thread that does the delegation token updates.
Original file line number Diff line number Diff line change @@ -132,7 +132,7 @@ class YarnSparkHadoopUtil extends SparkHadoopUtil {
132132 tokenRenewer.get.updateCredentialsIfRequired()
133133 }
134134
135- private [spark] override def stopExecutorDelegationTokenRenewer (): Unit = {
135+ private [spark] override def stopExecutorDelegationTokenRenewer (): Unit = {
136136 tokenRenewer.foreach(_.stop())
137137 }
138138
You can’t perform that action at this time.
0 commit comments