I think on 1.x you can work around it by directly accessing the Storm metrics registry. That's what TopologyContext would do when you use it https://github.com/apache/storm/blob/2ade13055315b69980f228ed786c6a76efb695a7/storm-core/src/jvm/org/apache/storm/task/TopologyContext.java#L397
Den tor. 4. apr. 2019 kl. 09.29 skrev Niraj Gupta <niraj...@gmail.com>: > Is there any way to use TopologyContext in the Trident StateFactory? > Also, I tried directly using Dropwizard metrics JMX reporter, which worked > on the single node setup but when I deployed on the cluster then those > metrics via my own reporter were not visible. > > On Thu, Apr 4, 2019 at 12:39 PM Stig Rohde Døssing <stigdoess...@gmail.com> > wrote: > >> There might be an issue with the API for StateFactory here. You need a >> TopologyContext to use the new metrics API, but makeState doesn't take one. >> Others can correct me if this is not an issue, but IMO feel free to >> register an issue at https://issues.apache.org/jira. >> >> Den tor. 4. apr. 2019 kl. 08.58 skrev Stig Rohde Døssing < >> stigdoess...@gmail.com>: >> >>> As far as I can tell, the JMX reporting is only hooked up to the metrics >>> v2 API. You're using metrics v1. Could you try to register your metric with >>> the new metrics system? You can find documentation at >>> https://storm.apache.org/releases/2.0.0-SNAPSHOT/metrics_v2.html. >>> >>> Den ons. 3. apr. 2019 kl. 15.41 skrev Niraj Gupta <niraj...@gmail.com>: >>> >>>> *Storm version*: 1.0.3 I'm registering custom metric in the makeState >>>> of the StateFactory implementation. >>>> >>>> @Overridepublic 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);} >>>> >>>> I have added the following jmx config in the 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 >>>> >>>> After running the Storm cluster when I'm connecting to the 3337 port >>>> then I'm not seeing this metrics which I had defined. >>>> >>>> What am I missing? >>>> >>>> -- >>>> Regards, >>>> Niraj Gupta >>>> +91 727533898 >>>> 0 >>>> >>>> >>>> -- >>>> Regards, >>>> Niraj Gupta >>>> +91 7275338980 >>>> >>>> >>>> -- >>>> Regards, >>>> Niraj Gupta >>>> +91 7275338980 >>>> >>> > > -- > Regards, > Niraj Gupta > +91 7275338980 >
