Bill Neubauer created BEAM-4141:
-----------------------------------
Summary: Data channel deadlocks when user function fails
Key: BEAM-4141
URL: https://issues.apache.org/jira/browse/BEAM-4141
Project: Beam
Issue Type: Bug
Components: sdk-go
Affects Versions: Not applicable
Reporter: Bill Neubauer
Assignee: Bill Neubauer
Fix For: Not applicable
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
