[ https://issues.apache.org/jira/browse/FLINK-25883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Konstantin Knauf updated FLINK-25883: ------------------------------------- Fix Version/s: 1.13.7 (was: 1.13.6) > The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large > ------------------------------------------------------------------------------ > > Key: FLINK-25883 > URL: https://issues.apache.org/jira/browse/FLINK-25883 > Project: Flink > Issue Type: Bug > Environment: Windows, Python 3.8 > Reporter: Mikhail > Assignee: Dian Fu > Priority: Minor > Fix For: 1.15.0, 1.12.8, 1.14.4, 1.13.7 > > > InĀ [this > line|https://github.com/apache/flink/blob/fb38c99a38c63ba8801e765887f955522072615a/flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py#L30], > the value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is set to > 3153600000. This is more than the default value of threading.TIMEOUT_MAX on > Windows Python, which is 4294967. Due to this, "OverflowError: timeout value > is too large" error is produced. > Full traceback: > {code:java} > File > "G:\PycharmProjects\PyFlink\venv_from_scratch\lib\site-packages\apache_beam\runners\worker\data_plane.py", > line 218, in run > while not self._finished.wait(next_call - time.time()): > File "C:\Python38\lib\threading.py", line 558, in wait > signaled = self._cond.wait(timeout) > File "C:\Python38\lib\threading.py", line 306, in wait > gotit = waiter.acquire(True, timeout) > OverflowError: timeout value is too large{code} -- This message was sent by Atlassian Jira (v8.20.1#820001)