Skip to content

Commit 072659e

Browse files
Fix build failure caused by thread factory getting moved to ThreadUtils.
1 parent f041dd3 commit 072659e

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

core/src/main/scala/org/apache/spark/deploy/ExecutorDelegationTokenUpdater.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,11 @@ package org.apache.spark.deploy
1919
import java.util.concurrent.{Executors, TimeUnit}
2020

2121
import org.apache.hadoop.conf.Configuration
22-
import org.apache.hadoop.fs.{FileStatus, FileSystem, Path}
22+
import org.apache.hadoop.fs.{FileSystem, Path}
2323
import org.apache.hadoop.security.{Credentials, UserGroupInformation}
2424

2525
import org.apache.spark.{Logging, SparkConf}
26-
import org.apache.spark.util.Utils
26+
import org.apache.spark.util.{ThreadUtils, Utils}
2727

2828
import scala.util.control.NonFatal
2929

@@ -37,7 +37,7 @@ private[spark] class ExecutorDelegationTokenUpdater(
3737

3838
private val delegationTokenRenewer =
3939
Executors.newSingleThreadScheduledExecutor(
40-
Utils.namedThreadFactory("Delegation Token Refresh Thread"))
40+
ThreadUtils.namedThreadFactory("Delegation Token Refresh Thread"))
4141

4242
// On the executor, this thread wakes up and picks up new tokens from HDFS, if any.
4343
private val executorUpdaterRunnable =

yarn/src/main/scala/org/apache/spark/deploy/yarn/AMDelegationTokenRenewer.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,12 @@ import java.security.PrivilegedExceptionAction
2020
import java.util.concurrent.{Executors, TimeUnit}
2121

2222
import org.apache.hadoop.conf.Configuration
23-
import org.apache.hadoop.fs.{FileStatus, FileSystem, Path}
23+
import org.apache.hadoop.fs.{FileSystem, Path}
2424
import org.apache.hadoop.security.UserGroupInformation
2525
import org.apache.spark.deploy.SparkHadoopUtil
2626

2727
import org.apache.spark.{Logging, SparkConf}
28-
import org.apache.spark.util.Utils
28+
import org.apache.spark.util.ThreadUtils
2929

3030
/*
3131
* The following methods are primarily meant to make sure long-running apps like Spark
@@ -54,7 +54,7 @@ private[yarn] class AMDelegationTokenRenewer(
5454

5555
private val delegationTokenRenewer =
5656
Executors.newSingleThreadScheduledExecutor(
57-
Utils.namedThreadFactory("Delegation Token Refresh Thread"))
57+
ThreadUtils.namedThreadFactory("Delegation Token Refresh Thread"))
5858

5959
private val hadoopUtil = YarnSparkHadoopUtil.get
6060

0 commit comments

Comments
 (0)