Mikhail created FLINK-25883:
-------------------------------
Summary: 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
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. Due to this, "OverflowError: timeout value is too large" error
is produced.
Full traceback:
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
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
