[ 
https://issues.apache.org/jira/browse/FLINK-39003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Emre Kartoglu updated FLINK-39003:
----------------------------------
    Description: 
The `millisBehindLatest` metric emitted by the Kinesis source connector

 

```

 <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kinesis</artifactId>
            <version>5.0.0-1.2</version>
</dependency>

```

appears to be inaccurate on app failover. It seems like there may be stale 
metric values registered in the metric system that are not getting cleared. 
Attached 

 

 

!Screenshot 2026-01-30 at 12.40.35.png!

  was:Draft: details coming


> Draft: Inaccurate millisBehindLatest metric from the Kinesis source connector 
> on failover
> -----------------------------------------------------------------------------------------
>
>                 Key: FLINK-39003
>                 URL: https://issues.apache.org/jira/browse/FLINK-39003
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Kinesis
>    Affects Versions: aws-connector-5.0.0
>            Reporter: Emre Kartoglu
>            Assignee: Emre Kartoglu
>            Priority: Major
>              Labels: AWS
>         Attachments: Screenshot 2026-01-30 at 12.40.35.png, Screenshot 
> 2026-01-30 at 12.47.00.png
>
>
> The `millisBehindLatest` metric emitted by the Kinesis source connector
>  
> ```
>  <dependency>
>             <groupId>org.apache.flink</groupId>
>             <artifactId>flink-connector-kinesis</artifactId>
>             <version>5.0.0-1.2</version>
> </dependency>
> ```
> appears to be inaccurate on app failover. It seems like there may be stale 
> metric values registered in the metric system that are not getting cleared. 
> Attached 
>  
>  
> !Screenshot 2026-01-30 at 12.40.35.png!



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to