Как я могу получить metricsSystem (org.apache.spark.metrics.MetricsSystem) внутри исполнителей?
Я пытаюсь отправить пользовательские метрики от моих исполнителей, для этого мне нужно использовать Метрическую систему Spark для регистрации пользовательского источника, который я написал.
Я могу получить метрическую систему в области драйверов
SparkEnv.get.metricsSystem
Но я не могу сделать то же самое в исполнителях. Согласно документации Spark, она должна быть доступна как-то.
Использование Spark 1.6.1
Связанные с - пост