Yan Fang created SAMZA-349:
------------------------------
Summary: MetricsSnapshotReporter does not refresh metrics every 60
seconds
Key: SAMZA-349
URL: https://issues.apache.org/jira/browse/SAMZA-349
Project: Samza
Issue Type: Bug
Reporter: Yan Fang
If my understanding is correct, the metrics we provide are for every 60 seconds
and all counters will be reset every 60 seconds. Current the
MetricsSnapshotReporter seems missing this implementation. It sends out the
metrics every 60 seconds but does not reset the counter value.
{code}
registry.getGroup(group).foreach {
case (name, metric) =>
metric.visit(new MetricsVisitor {
def counter(counter: Counter) = groupMsg.put(name,
counter.getCount: java.lang.Long)
def gauge[T](gauge: Gauge[T]) = groupMsg.put(name,
gauge.getValue.asInstanceOf[Object])
})
}
{code}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
