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)
