tvalentyn commented on code in PR #28781:
URL: https://github.com/apache/beam/pull/28781#discussion_r1346365077
##########
sdks/python/apache_beam/runners/worker/sdk_worker.py:
##########
@@ -162,8 +162,7 @@ def __init__(
control_address, # type: str
credentials=None, # type: Optional[grpc.ChannelCredentials]
worker_id=None, # type: Optional[str]
- # Caching is disabled by default
- state_cache_size=0, # type: int
+ state_cache_size=100 << 20, # type: int
Review Comment:
naming is tricky - what is worker? is cache per entire VM (answer, for
python it is per process).. might be better to iron that out in a doc.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
