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)