Skip to content

Commit c501a2c

Browse files
committed
Address the comments
1 parent d237ba5 commit c501a2c

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

core/src/main/scala/org/apache/spark/ExecutorAllocationManager.scala

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ private[spark] class ExecutorAllocationManager(
148148
ThreadUtils.newDaemonSingleThreadScheduledExecutor("spark-dynamic-executor-allocation")
149149

150150
// Metric source for ExecutorAllocationManager to expose internal status to MetricsSystem.
151-
private[spark] val executorAllocationManagerSource = new ExecutorAllocationManagerSource
151+
val executorAllocationManagerSource = new ExecutorAllocationManagerSource
152152

153153
/**
154154
* Verify that the settings specified through the config are valid.
@@ -585,9 +585,11 @@ private[spark] class ExecutorAllocationManager(
585585
}
586586
}
587587

588-
// Metric source for ExecutorAllocationManager to expose the its internal executor allocation
589-
// status to MetricsSystem.
590-
// Note: these metrics may not be stable across Spark version.
588+
/**
589+
* Metric source for ExecutorAllocationManager to expose its internal executor allocation
590+
* status to MetricsSystem.
591+
* Note: These metrics may not be stable across Spark version.
592+
*/
591593
private[spark] class ExecutorAllocationManagerSource extends Source {
592594
val sourceName = "ExecutorAllocationManager"
593595
val metricRegistry = new MetricRegistry()

0 commit comments

Comments
 (0)