I am not sure if it is by design or just unnoticed problem, or my mistake
somewhere but I am getting following behavior:
I pass Properties object as a parameter while registering my custom metrics
consumer:
conf.registerMetricsConsumer(SomeMetricsConsumer.class, new Properties(),
1);
and there I get a class cast exception:
public void prepare(Map stormConf, Object registrationArgument,
TopologyContext context, IErrorReporter errorReporter) {
Properties props = (Properties) registrationArgument;
}
The type that I am getting is now clojure.lang.PersistentHashMap.
I have a workaround, just want to share in case someone else runs into he
same problem.
----------
Andrey Yegorov
