@@ -588,7 +588,9 @@ private[spark] class ExecutorAllocationManager(
588588 /**
589589 * Metric source for ExecutorAllocationManager to expose its internal executor allocation
590590 * status to MetricsSystem.
591- * Note: These metrics may not be stable across Spark version.
591+ * Note: These metrics heavily rely on the internal implementation of
592+ * ExecutorAllocationManager, metrics or value of metrics will be changed when internal
593+ * implementation is changed, so these metrics are not stable across Spark version.
592594 */
593595 private [spark] class ExecutorAllocationManagerSource extends Source {
594596 val sourceName = " ExecutorAllocationManager"
@@ -601,10 +603,9 @@ private[spark] class ExecutorAllocationManager(
601603 }
602604
603605 registerGauge(" numberExecutorsToAdd" , numExecutorsToAdd, 0 )
604- registerGauge(" numberExecutorsPending" , numExecutorsPending, 0 )
605606 registerGauge(" numberExecutorsPendingToRemove" , executorsPendingToRemove.size, 0 )
606607 registerGauge(" numberAllExecutors" , executorIds.size, 0 )
607- registerGauge(" numberTargetExecutors" , targetNumExecutors() , 0 )
608+ registerGauge(" numberTargetExecutors" , numExecutorsTarget , 0 )
608609 registerGauge(" numberMaxNeededExecutors" , maxNumExecutorsNeeded(), 0 )
609610 }
610611}
0 commit comments