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

Make blocking result partitions consumable multiple times

    XMLWordPrintableJSON

Details

    Description

      In order to avoid writing produced results multiple times for multiple consumers and in order to speed up batch recoveries, we should make the blocking result partitions to be consumable multiple times. At the moment a blocking result partition will be released once the consumers has processed all data. Instead the result partition should be released once the next blocking result has been produced and all consumers of a blocking result partition have terminated. Moreover, blocking results should not hold on slot resources like network buffers or memory as it is currently the case with SpillableSubpartitions.

      Attachments

        Issue Links

          Activity

            People

              sewen Stephan Ewen
              trohrmann Till Rohrmann
              Votes:
              0 Vote for this issue
              Watchers:
              20 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 - 1h
                  1h