Luke Cwik created BEAM-10959:
--------------------------------
Summary: Fix race where split/progress calls return "Unknown
process bundle instruction" since initialization of BundleProcessor happens in
a separate thread
Key: BEAM-10959
URL: https://issues.apache.org/jira/browse/BEAM-10959
Project: Beam
Issue Type: Bug
Components: sdk-py-harness
Reporter: Luke Cwik
Assignee: Luke Cwik
Currently there is a race where a BundleProcessor doesn't exist until another
thread picks up the task and inserts into the active set. This allows for
split/progress calls to happen and error out with "Unknown process bundle
instruction X".
Since the control stream is ordered, we can guarantee that an uninitialized
BundleProcessor exists that can respond to this really early split/progress
calls.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
