Версия Storm : 1.0.3
Я регистрирую пользовательскую метрику в makeState реализации StateFactory.
@Override
public State makeState(final Map conf, final IMetricsContext metricsContext, final int partitionIndex, final int numPartitions) {
ReducedMetric reducedMetric = new ReducedMetric(new MeanReducer());
metricsContext.registerMetric("custom-metric-1", reducedMetric, 1);
reducedMetric.update(100);
}
Я добавил следующую конфигурацию jmx в storm.yml
-Dcom.sun.management.jmxremote.port=3337 -Dcom.sun.management.jmxremote.local.only=false -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false
После запуска кластера Storm при подключении к порту 3337 я не вижу метрик, которые я определил.
Любая помощь будет оценена!