Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-14551 Unaligned checkpoints
  3. FLINK-14553

Respect non-blocking output in StreamTask#processInput

    XMLWordPrintableJSON

    Details

      Description

      The non-blocking output was introduced in FLINK-14396 and FLINK-14498 to solve the problem of handling the checkpoint barrier in the case of backpressure.

      In order to make the whole process through, StreamInputProcessor should be allowed to process input elements if the output is also available.

      The default core size of LocalBufferPool for ResultPartition should also be increased by 1 in order not to impact the performance in the new way, and this tiny memory overhead could be ignored in practice.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                zjwang Zhijiang
                Reporter:
                zjwang Zhijiang
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m