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

Process checkpoint barrier in AsyncWaitOperator when the element queue is full

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Minor
    • Resolution: Unresolved
    • None
    • None
    • Runtime / Task
    • None

    Description

      As discussed in https://lists.apache.org/thread/4f7ywn29kdv4302j2rq3fkxc6pc8myr2 . Maybe it is better to provide such a new `yield` that can process mail with low priority in the mailbox executor. More discussion needed.

      Attachments

        Issue Links

          relates to

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-35051 Weird priorities when processing unaligned checkpoints

          • Major - Major loss of function.
          • Open

          Activity

            People

              Unassigned Unassigned
              zakelly Zakelly Lan
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated: