[FLINK-22172] Fix the bug of shared resource among Python Operators of the same slot is not released

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.12.2, 1.13.0
• Fix Version/s: 1.13.0, 1.12.3
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Huang Xingbo
• Reporter: Huang Xingbo
• Created: 09/Apr/21 06:31
• Updated: 28/May/21 09:02
• Resolved: 10/Apr/21 03:01

Description

The problem was discussed here:
https://issues.apache.org/jira/browse/FLINK-20663?focusedCommentId=17317706&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-17317706

In general, the python process should be terminated when the shared resource is released as many times as requested. However, this reference counting logic has been implemented twice. Consequently, the shared resource may be requested multiple times but only released once.

Issue Links

• links to: GitHub Pull Request #15537