Re: Registering custom metrics does not work

How are you verifying whether it is registered? For the sake of covering all angles: Are you certain that createPartitionIndex is called? On 06.07.2017 08:51, wyphao.2007 wrote: Hi Chesnay, thank you for your reply The code above does not get registered at all. 在2017年07月06 14时45分,

Re:Re: Registering custom metrics does not work

Hi Chesnay, thank you for your reply The code above does not get registered at all. 在2017年07月06 14时45分, "Chesnay Schepler"写道: Hello, Plase provide more information as to how it is not working as expected. Does it throw an

Re: Registering custom metrics does not work

Hello, Plase provide more information as to how it is not working as expected. Does it throw an exception, log a warning, is the metric not get registered at all or does the value not changing? On 06.07.2017 08:10, wyphao.2007 wrote: Hi, all I want to know element's latency before write to

Registering custom metrics does not work

Hi, all I want to know element's latency before write to Elasticsearch, so I registering a custom metrics as follow: class CustomElasticsearchSinkFunction extends ElasticsearchSinkFunction[EventEntry] { private var metricGroup: Option[MetricGroup] = None private var latency: Long = _