Jozef Vilcek created BEAM-4521: ---------------------------------- Summary: Backlog metrics not showing up Key: BEAM-4521 URL: https://issues.apache.org/jira/browse/BEAM-4521 Project: Beam Issue Type: Bug Components: io-java-kafka Affects Versions: 2.4.0 Reporter: Jozef Vilcek Assignee: Raghu Angadi
Hello, I wanted to track _backlog_bytes_ and _backlog_elements_ metrics from SinkMetrics for kafka. I see in the code that KafkaUnboundedReader is reporting them but was not able to get them visible (running on Flink). Metrics are reported here: [https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java#L668] In Flink runtime I noticed this message: {code:java} 2018-06-07 08:53:53,216 ERROR org.apache.beam.sdk.metrics.MetricsEnvironment - Unable to update metrics on the current thread. Most likely caused by using metrics outside the managed work-execution thread. {code} I see that backlog is reported from getCheckpointMark(), which is done by some other thread. Not sure why it is done there. I tested locally to move it to the advance() method, where bytes_read is reported and it worked. -- This message was sent by Atlassian JIRA (v7.6.3#76005)