You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2018/12/17 00:05:00 UTC
[jira] [Commented] (KAFKA-7176) State store metrics for migrated
tasks are not removed
[ https://issues.apache.org/jira/browse/KAFKA-7176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722610#comment-16722610 ]
Guozhang Wang commented on KAFKA-7176:
--------------------------------------
I've looked into trunk again and I believe it's been fixed now with [~vvcephei]'s fix. John, could you confirm? If yes please feel free to resolve it with the fix versions.
> State store metrics for migrated tasks are not removed
> ------------------------------------------------------
>
> Key: KAFKA-7176
> URL: https://issues.apache.org/jira/browse/KAFKA-7176
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 1.1.0
> Reporter: Sam Lendle
> Priority: Major
>
> I observed that state store metrics for tasks that have been migrated to other instances are not removed and are still being updated with phantom values, (when viewed for example via jmx mbeans).
> For all tasks/threads on the same instance (including for migrated tasks), the values of state store metrics are all (nearly) the same. For the rate metrics at least, the value reported for each task is the rate I expect for all active tasks on that instance, so things are apparently being counted multiple times. Presumably, this is how migrated task metrics are being updated.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)