[FLINK-12843] Refactor the pin logic in ReleaseOnConsumptionResultPartition

• Type: Sub-task
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 14/Jun/19 04:28
• Updated: 19/Jun/19 14:09
• Resolved: 19/Jun/19 14:09

Description

The pin logic is for adding the reference counter based on number of subpartitions for ReleaseOnConsumptionResultPartition.

It seems not necessary to do it in while loop as now, because the atomic counter would not be accessed by other threads during pin. If the ReleaseOnConsumptionResultPartition was not created yet, the createSubpartitionView would not be called actually resulting in PartitionNotFoundException. 

So we could simple increase the reference counter in ReleaseOnConsumptionResultPartition constructor directly.

Issue Links

• links to: GitHub Pull Request #8763