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
          KevinyhZou
        2. image-2020-11-26-12-00-55-829.png
          264 kB
          KevinyhZou

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: