Elphas Toringepi created FLINK-23705:
----------------------------------------

             Summary: Unregister MetricGroup after shard closes in Kinesis 
connector
                 Key: FLINK-23705
                 URL: https://issues.apache.org/jira/browse/FLINK-23705
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kinesis
    Affects Versions: 1.13.2, 1.13.1, 1.13.0
            Reporter: Elphas Toringepi
             Fix For: 1.13.2, 1.13.1, 1.13.0


Kinesis connector continues to report metrics for closed shards after 
resharding leading to incorrect millisBehindLatest metric reported on the Flink 
dashboard.

This is results in incorrect aggregated metrics for the entire stream even 
after restarting.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to