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

Posted to issues@flink.apache.org by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/05/05 15:18:00 UTC

[jira] [Updated] (FLINK-30289) RateLimitedSourceReader uses wrong signal for checkpoint rate-limiting

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

Yuepeng Pan updated FLINK-30289:
--------------------------------
    Fix Version/s: 2.4.0
                       (was: 2.3.0)

> RateLimitedSourceReader uses wrong signal for checkpoint rate-limiting
> ----------------------------------------------------------------------
>
>                 Key: FLINK-30289
>                 URL: https://issues.apache.org/jira/browse/FLINK-30289
>             Project: Flink
>          Issue Type: Bug
>          Components: API / Core
>    Affects Versions: 2.1.0
>            Reporter: Chesnay Schepler
>            Assignee: Chesnay Schepler
>            Priority: Major
>              Labels: pull-request-available, stale-assigned
>             Fix For: 2.4.0
>
>
> The checkpoint rate limiter is notified when the checkpoint is complete, but since this signal comes at some point in the future (or not at all) it can result in no records being emitted for a checkpoint, or more records than expected being emitted.



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