Håkon Hitland created BEAM-5206:
-----------------------------------

             Summary: Thread local caching of GcsIO instances does not work
                 Key: BEAM-5206
                 URL: https://issues.apache.org/jira/browse/BEAM-5206
             Project: Beam
          Issue Type: Bug
          Components: sdk-py-core
    Affects Versions: 2.6.0
            Reporter: Håkon Hitland
            Assignee: Ahmet Altay


gcsio.py contains some code to cache new instances per thread:
  
{code:java}
local_state = threading.local()
if getattr(local_state, 'gcsio_instance', None) is None:
{code}
However, since local_state is always a newly created thread-local storage, this 
property will never be set.

To get the intended effect, a global threading.local() instance should be 
stored on the class or module level.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to