Unregistering metric reporting for closed shards

awslabs / amazon-kinesis-connector-flink

This is a fork of the Apache Flink Kinesis connector adding Enhanced Fanout support for Flink 1.8/1.11 on KDA.

Apache License 2.0

21 stars 11 forks source link

Unregistering metric reporting for closed shards #45

Closed elphastori closed 3 years ago

elphastori commented 3 years ago

Description of changes: Unregister metric reports for closed/complete shards. Fixes a bug where confusing aggregated metrics are shown after resharding.

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.