This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.13 by this push:
new f71cbb9 [FLINK-25883][python] Set the default value of
DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S to 30 days
f71cbb9 is described below
commit f71cbb9a8a6349411a158ee0d9faf5253fa15d35
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 15e12cd..ea9307a 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 main():
