Chesnay Schepler created FLINK-12993:
----------------------------------------
Summary: Rework forceReleaseOnConsumptionFlag to be JM internal
concept
Key: FLINK-12993
URL: https://issues.apache.org/jira/browse/FLINK-12993
Project: Flink
Issue Type: Improvement
Components: Runtime / Network
Affects Versions: 1.9.0
Reporter: Chesnay Schepler
Assignee: Chesnay Schepler
Fix For: 1.9.0
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
