[
https://issues.apache.org/jira/browse/FLINK-25883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail updated FLINK-25883:
----------------------------
Description:
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:
{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}
was:
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:
{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}
> 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
> Priority: Minor
>
> 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:
> {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)
