This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push:
new 77e65db [FLINK-25883][python] Set the default value of
DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S to 30 days
77e65db is described below
commit 77e65db61aeccb35a6015e74de3f647db796774c
Author: Dian Fu <[email protected]>
AuthorDate: Mon Feb 14 11:52:01 2022 +0800
[FLINK-25883][python] Set the default value of
DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S to 30 days
---
flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py
b/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py
index b98f28b..4cf430d 100644
--- a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py
+++ b/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py
@@ -27,7 +27,7 @@ import apache_beam.runners.worker.sdk_worker_main
# disable bundle processor shutdown
from apache_beam.runners.worker import sdk_worker
-sdk_worker.DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S = 86400 * 365 *
100
+sdk_worker.DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S = 86400 * 30
def print_to_logging(logging_func, msg, *args, **kwargs):
