Luis De Pombo created SAMZA-691:
-----------------------------------
Summary: messages-chosen counter in SystemConsumersMetrics
registerSystemStream without identifying the partition
Key: SAMZA-691
URL: https://issues.apache.org/jira/browse/SAMZA-691
Project: Samza
Issue Type: Bug
Components: metrics
Reporter: Luis De Pombo
Priority: Minor
Running a samza job that consumes from a topic with 3 partitions (3 samza
tasks) in the same container we get the following message for collision of
metric names:
2015-05-27 15:10:32 SamzaGraphiteReporter [INFO] Exception while registering
for onCounter: java.lang.IllegalArgumentException: A metric named
org_apache_samza_system_SystemConsumersMetrics.samza-container-0.kafka-trip_details-messages-chosen
already exists
2015-05-27 15:10:32 SamzaGraphiteReporter [INFO] Exception while registering
for onCounter: java.lang.IllegalArgumentException: A metric named
org_apache_samza_system_SystemConsumersMetrics.samza-container-0.kafka-trip_details-messages-chosen
already exists
Samza counter "messages-chosen" is registered per system stream without
identifying by partition or source. It must include partition or only include
the system so the metric name can be unique under all scenarios.
def registerSystemStream(systemStream: SystemStream) {
systemStreamMessagesChosen += systemStream ->
newCounter("%s-%s-messages-chosen" format (systemStream.getSystem,
systemStream.getStream))
}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
