You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/06/08 02:50:00 UTC

[jira] [Created] (FLINK-27948) Unifying how result partition should be released

Weijie Guo created FLINK-27948:
----------------------------------

             Summary: Unifying how result partition should be released
                 Key: FLINK-27948
                 URL: https://issues.apache.org/jira/browse/FLINK-27948
             Project: Flink
          Issue Type: Improvement
            Reporter: Weijie Guo


For pipelined result partitions, intermediate data will be released with downstream consumption. For the blocking result partition, the intermediate data will be released by JM by sending RPC after all downstream tasks are finished. Please let me know if I got something wrong.
Can we have a unified way to decide the release logic of a partition.In the long run, I think that's something to consider.



--
This message was sent by Atlassian Jira
(v8.20.7#820007)