From 526b83aa76b345a369c8b416b67d77c0f4d0c79d Mon Sep 17 00:00:00 2001 From: Anand Inguva Date: Fri, 6 Oct 2023 17:04:33 -0400 Subject: [PATCH 1/2] Update state cache size to 100 MB --- sdks/python/apache_beam/runners/worker/sdk_worker_main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py index d3442fcb5987..9953e8cc4ee2 100644 --- a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py +++ b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py @@ -256,7 +256,7 @@ def _get_state_cache_size(experiments): return int( re.match(r'state_cache_size=(?P.*)', experiment).group('state_cache_size')) << 20 - return 0 + return 100 << 20 def _get_data_buffer_time_limit_ms(experiments): From ee274afde16e5517344bad619b8c284ed0087864 Mon Sep 17 00:00:00 2001 From: tvalentyn Date: Fri, 6 Oct 2023 14:46:35 -0700 Subject: [PATCH 2/2] Update comment --- sdks/python/apache_beam/runners/worker/sdk_worker_main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py index 9953e8cc4ee2..1e44a998ba05 100644 --- a/sdks/python/apache_beam/runners/worker/sdk_worker_main.py +++ b/sdks/python/apache_beam/runners/worker/sdk_worker_main.py @@ -247,7 +247,7 @@ def _get_state_cache_size(experiments): Returns: an int indicating the maximum number of megabytes to cache. - Default is 0 MB + Default is 100 MB """ for experiment in experiments: