Sam Whittle created BEAM-11401:
----------------------------------

             Summary: StreamingDataflowWorker ReaderCache performs blocking 
close of readers on possibly important threads
                 Key: BEAM-11401
                 URL: https://issues.apache.org/jira/browse/BEAM-11401
             Project: Beam
          Issue Type: Bug
          Components: runner-dataflow
            Reporter: Sam Whittle
            Assignee: Sam Whittle


Currently closing can be performed when acquiring an unrelated reader, caching 
an unrelated reader, or invalidating readers.

Such closing could be performed in the background to ensure that it doesn't 
block unrelated processing or important threads (such as grpc commit stream).





--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to