> On 16. May 2019, at 20:06, Stig Rohde Døssing <[email protected]> wrote:
> 
> I may be completely off base with this, but I think metrics reporters are 
> configured in the cluster configuration, and not on a per-topology basis. 
> Note how the documentation you linked sets the config in storm.yaml, rather 
> than in the topology configuration.
> 
> Could you try putting the metrics configuration in the cluster configuration 
> instead? On 1.x you would do this by making your LocalCluster via the 
> Testing.withLocalCluster method. That method takes a MkClusterParam, which 
> takes the cluster config map. Example here 
> https://github.com/xumingming/storm-lib/blob/50394ff463da0d92ac4e07dee78a664a3a227e9c/src/jvm/storm/TestingApiDemo.java#L88
> 

This did it (at least for my 1.2.2 setup), thank you!

I thought this should be configured in the topology because the filter 
expression refers to my_component.

Btw, there's still an error in the the documentation I linked: the CsvReporter 
is called CsvStormReporter. I'll send a PR.


Best
Manuel

Reply via email to