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)