Skip to content

Commit

Permalink
rebase and address the comments
Browse files Browse the repository at this point in the history
  • Loading branch information
jerryshao committed May 2, 2015
1 parent c501a2c commit 104d155
Showing 1 changed file with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -588,7 +588,9 @@ private[spark] class ExecutorAllocationManager(
/**
* Metric source for ExecutorAllocationManager to expose its internal executor allocation
* status to MetricsSystem.
* Note: These metrics may not be stable across Spark version.
* Note: These metrics heavily rely on the internal implementation of
* ExecutorAllocationManager, metrics or value of metrics will be changed when internal
* implementation is changed, so these metrics are not stable across Spark version.
*/
private[spark] class ExecutorAllocationManagerSource extends Source {
val sourceName = "ExecutorAllocationManager"
Expand All @@ -601,10 +603,9 @@ private[spark] class ExecutorAllocationManager(
}

registerGauge("numberExecutorsToAdd", numExecutorsToAdd, 0)
registerGauge("numberExecutorsPending", numExecutorsPending, 0)
registerGauge("numberExecutorsPendingToRemove", executorsPendingToRemove.size, 0)
registerGauge("numberAllExecutors", executorIds.size, 0)
registerGauge("numberTargetExecutors", targetNumExecutors(), 0)
registerGauge("numberTargetExecutors", numExecutorsTarget, 0)
registerGauge("numberMaxNeededExecutors", maxNumExecutorsNeeded(), 0)
}
}
Expand Down

0 comments on commit 104d155

Please sign in to comment.