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

Partition commit is delayed when records keep coming

    XMLWordPrintableJSON

    Details

      Description

      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.

        Attachments

        1. image-2020-11-26-12-00-23-542.png
          18 kB
          zouyunhe
        2. image-2020-11-26-12-00-55-829.png
          264 kB
          zouyunhe

          Issue Links

            Activity

              People

              • Assignee:
                lzljs3620320 Jingsong Lee
                Reporter:
                lzljs3620320 Jingsong Lee
              • Votes:
                0 Vote for this issue
                Watchers:
                7 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: