[FLINK-12993] Rework forceReleaseOnConsumptionFlag to be JM internal concept

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.9.0
• Fix Version/s: 1.9.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Chesnay Schepler
• Reporter: Chesnay Schepler
• Created: 26/Jun/19 07:47
• Updated: 26/Jun/19 14:48
• Resolved: 26/Jun/19 14:48

Description

The forceReleaseOnConsumption flag is currently evaluated on the TM side deep in the netty shuffle environment.

We can rework this to be evaluated on the JM side, by setting the releasedOnConsumption flag in the ResultPartitionDeploymentDescriptor appropriately.

This consolidates the setting of releasedOnConsumption on the JM, and also allows this to be used with other shuffle service implementations.

Issue Links

• links to: GitHub Pull Request #8896