[FLINK-31083] Python ProcessFunction with OutputTag cannot be reused

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.16.1
• Fix Version/s: 1.17.0, 1.16.2
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Juntao Hu
• Reporter: Juntao Hu
• Created: 15/Feb/23 09:30
• Updated: 15/Feb/23 11:28
• Resolved: 15/Feb/23 11:28

Description

output_tag = OutputTag("side", Types.STRING())

def udf(i):
    yield output_tag, i

ds1.map(udf).get_side_output(output_tag)
ds2.map(udf)

raises TypeError: cannot pickle '_thread.RLock' object

Issue Links

• links to: GitHub Pull Request #21941