storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Romeo Nocon <romeo.no...@gmail.com>
Subject Re: Is there a way to register metrics in flux yaml
Date Thu, 16 Feb 2017 18:56:13 GMT
Hi,

I'm using an older version of storm (0.9.4) and flux so I'm not sure this
will work on newer versions.  I also don't know anythign about
FluxShellBolts.  That said I put "topology.metrics.consumer.register" in
the config section of flux file. Yes it's a hack.

config
  ...

  topology.metrics.consumer.register:

  - class: "com.company.GraphiteMetricsConsumer"

    parallelism.hint: ${topo.metrics.graphite.parallelism}


Then I let the code do the rest.  Below is a quick grep of some relevant
files.

grep -ir topology.metrics.consumer.register *

storm-core/src/jvm/org/apache/storm/Config.java:    public static final
String TOPOLOGY_METRICS_CONSUMER_REGISTER =
"topology.metrics.consumer.register";

storm-core/src/jvm/org/apache/storm/Config.java:        List l =
(List)conf.get(TOPOLOGY_METRICS_CONSUMER_REGISTER);

storm-core/src/jvm/org/apache/storm/Config.java:
conf.put(TOPOLOGY_METRICS_CONSUMER_REGISTER, l);

storm-core/src/jvm/org/apache/storm/daemon/StormCommon.java:
List<Map<String, Object>> registerInfo = (List<Map<String, Object>>)
conf.get(Config.TOPOLOGY_METRICS_CONSUMER_REGISTER);

On Wed, Feb 15, 2017 at 11:24 AM, P. Taylor Goetz <ptgoetz@gmail.com> wrote:

> Hi Marc,
>
> Currently there is not a way to directly register metrics using Flux. It
> is something that is probably doable, though. Feel free to file a JIRA to
> add this functionality.
>
> -Taylor
>
> > On Feb 15, 2017, at 1:49 PM, Marc Zbyszynski <mmmzzz@gmail.com> wrote:
> >
> > Hello Everyone,
> >
> > I am using flux to deploy multilang topologies with a lot of
> FluxShellBolt instances. Do you know if there is any way to register a
> metric directly in the flux yaml without writing any Java code? I know that
> the multilang protocol supports submitting data to metrics that have been
> registered, but I don't see any way to register the metrics in Flux or by
> invoking a method on FluxShellBolt. Is that right, or am I missing
> something?
> >
> > Thank you for your help!
> >
> > -Marc
>
>

Mime
View raw message