Как получить использование памяти и ЦП из кластера - PullRequest
Новая
       21

Как получить использование памяти и ЦП из кластера

0 голосов
/ 27 сентября 2019

Мы используем AWS EMR для запуска искровых заданий.Из ганглиев мы видим, что использование памяти нашего кластера низкое по сравнению с выделенной памятью.Это относится и к использованию процессора.

В настоящее время мы сообщаем о метриках искры, внедряя прослушиватель Spark.Но я не могу найти, как получить метрики ганглиев из кода искры.Доступна ли эта информация где-нибудь и в искровых событиях?

1 Ответ

0 голосов
/ 28 сентября 2019

Вы можете попробовать sparklens (https://github.com/qubole/sparklens), чтобы сначала узнать правильное количество исполнителей для вашего приложения spark, а затем настроить кластер соответствующим образом. Использование кластера также зависит от характеристик масштабируемости приложения.

Чтобы получитьметрики spark JMX

1) Создайте файл metrics.properties в spark / conf /

*. sink.jmx.class = org.apache.spark.metrics.sink.JmxSinkdriver.source.jvm.class = org.apache.spark.metrics.source.JvmSource executor.source.jvm.class = org.apache.spark.metrics.source.JvmSource master.source.jvm.class = org.apache.spark.metrics.source.JvmSource worker.source.jvm.class = org.apache.spark.metrics.source.JvmSource

2) Загрузите jarokai agent jar в какое-то место в вашем кластере.Другие агенты JMX также должны работать.

3) Обновите следующие переопределения Spark:

spark.metrics.conf spark / conf / metrics.properties spark.driver.extraJavaOptions -Djava.net.preferIPv4Stack = true -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port = 8090 -Dcom.sun.management.jmxremote.authenticate = false -Dcom.sun.management.jmxremote.ssl = false -javaagent: / tmp / jolokia-jvm.jar = port = 8779, host = localhost spark.executor.extraJavaOptions -Djava.net.preferIPv4Stack = true -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port = 8091 -Dcom.sun.management.jmxremote.authenticate = false -Dcom.sun.management.jmxremote.ssl = false -javaagent: /tmp/jolokia-jvm.jar=port=8781,host=localhost "

4) Использоватьтелеграф или другие инструменты мониторинга для получения метрик от агентов.

...