Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-23705

Unregister MetricGroup after shard closes in Kinesis connector

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 1.6.3, 1.6.4, 1.7.2, 1.8.0, 1.8.1, 1.8.2, 1.8.3, 1.9.0, 1.9.1, 1.9.2, 1.9.3, 1.10.0, 1.10.1, 1.10.2, 1.10.3, 1.11.0, 1.11.1, 1.11.2, 1.11.3, 1.11.4, 1.12.0, 1.12.1, 1.12.2, 1.13.0, 1.12.3, 1.13.1, 1.12.4, 1.12.5, 1.13.2
    • 1.14.0, 1.13.3
    • Connectors / Kinesis

    Description

      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.

      Attachments

        Activity

          People

            elphastori Elphas Toringepi
            elphastori Elphas Toringepi
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: