Skip to content

Commit 9a6697c

Browse files
committed
[SPARK-50811][FOLLOWUP] Remove profiler executor enabled check in SparkAsyncProfiler
1 parent 8222670 commit 9a6697c

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

connector/profiler/src/main/scala/org/apache/spark/profiler/SparkAsyncProfiler.scala

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,6 @@ import org.apache.spark.util.{ThreadUtils, Utils}
3636
private[spark] class SparkAsyncProfiler(conf: SparkConf, executorId: String) extends Logging {
3737

3838
private var running = false
39-
private val enableProfiler = conf.get(PROFILER_EXECUTOR_ENABLED)
4039
private val profilerOptions = conf.get(PROFILER_ASYNC_PROFILER_OPTIONS)
4140
private val profilerDfsDirOpt = conf.get(PROFILER_DFS_DIR)
4241
private val profilerLocalDir = conf.get(PROFILER_LOCAL_DIR)
@@ -67,9 +66,7 @@ private[spark] class SparkAsyncProfiler(conf: SparkConf, executorId: String) ext
6766
@volatile private var writing: Boolean = false
6867

6968
val profiler: Option[AsyncProfiler] = {
70-
Option(
71-
if (enableProfiler && AsyncProfilerLoader.isSupported) AsyncProfilerLoader.load() else null
72-
)
69+
Option(if (AsyncProfilerLoader.isSupported) AsyncProfilerLoader.load() else null)
7370
}
7471

7572
def start(): Unit = {

0 commit comments

Comments
 (0)