You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Elphas Toringepi (Jira)" <ji...@apache.org> on 2021/08/10 09:39:00 UTC

[jira] [Created] (FLINK-23705) Unregister MetricGroup after shard closes in Kinesis connector

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)