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

Posted to dev@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/11/18 09:47:00 UTC

[jira] [Created] (FLINK-20213) Partition commit is delayed when records keep coming

Jingsong Lee created FLINK-20213:
------------------------------------

             Summary: Partition commit is delayed when records keep coming
                 Key: FLINK-20213
                 URL: https://issues.apache.org/jira/browse/FLINK-20213
             Project: Flink
          Issue Type: Bug
          Components: Connectors / FileSystem
    Affects Versions: 1.11.2
            Reporter: Jingsong Lee
            Assignee: Jingsong Lee
             Fix For: 1.12.0


When set partition-commit.delay=0, Users expect partitions to be committed immediately.

However, if the record of this partition continues to flow in, the bucket for the partition will be activated, and no inactive bucket will appear.

We need to consider listening to bucket created.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)