Thomas Weise created BEAM-5211:
----------------------------------
Summary: Flink Streaming ExecutableStage operator chain blocks
grpc receiver threads
Key: BEAM-5211
URL: https://issues.apache.org/jira/browse/BEAM-5211
Project: Beam
Issue Type: Bug
Components: runner-flink
Affects Versions: 2.6.0
Reporter: Thomas Weise
Assignee: Thomas Weise
Fix For: 2.7.0
The operator attempts to emit results as they are received, within the grpc
thread, while the subtask thread is waiting for bundle completion. This leads
to blocking of grpc threads and eventually deadlock when multiple stages are
within an operator chain. See attached stacktrace.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
