[BEAM-4141] Data channel deadlocks when user function fails

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: Not applicable
• Fix Version/s: Not applicable
• Component/s: sdk-go
• Assignee: Bill Neubauer
• Reporter: Bill Neubauer
• Created: 19/Apr/18 16:37
• Updated: 16/May/20 13:44
• Resolved: 18/May/18 23:46

Description

There is a deadlock condition in the data channel code that occurs when a user function fails while processing an element. The producer for the data channel is continuing to send information across a channel, but the intended consumer has stopped listening. Unfortunately, this channel blocks the entire data channel, blocking data for any other DoFn that might be running, causing the whole worker to deadlock.

Issue Links

• links to: GitHub Pull Request #5184