Maximilian Michels created BEAM-8403:
----------------------------------------
Summary: Race condition in request id generation of
GrpcStateRequestHandler
Key: BEAM-8403
URL: https://issues.apache.org/jira/browse/BEAM-8403
Project: Beam
Issue Type: Bug
Components: sdk-py-harness
Reporter: Maximilian Michels
Assignee: Maximilian Michels
Fix For: 2.17.0
There is a race condition in {{GrpcStateRequestHandler}} which surfaced after
the recent changes to process append/clear state request asynchronously. The
race condition can occur if multiple Runner workers process a transform with
state requests with the same SDK Harness. For example, this setup occurs with
Flink when a TaskManager has multiple task slots and two or more of those slots
process the same stateful stage against an SDK Harness.
CC [~robertwb]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
