[
https://issues.apache.org/jira/browse/FLINK-24880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487850#comment-17487850
]
Dian Fu commented on FLINK-24880:
---------------------------------
[~kafkachris] Oh, thanks for reporting this issue. It seems that it doesn't
handle correctly for a corner case. Have submitted a
[PR|https://github.com/apache/flink/pull/18640] to address it. Besides, I think
it should not affect the execution of PyFlink jobs as it only occurs when
stopping jobs and you could just ignore it for now. Feel free to correct me if
this is not the case for your job.
> Error messages "OverflowError: timeout value is too large" shown when
> executing PyFlink jobs
> --------------------------------------------------------------------------------------------
>
> Key: FLINK-24880
> URL: https://issues.apache.org/jira/browse/FLINK-24880
> Project: Flink
> Issue Type: Improvement
> Components: API / Python
> Affects Versions: 1.14.0
> Environment: Python 3.6.8 (tags/v3.6.8:3c6b436a57, Dec 24 2018,
> 00:16:47) [MSC v.1916 64 bit (AMD64)] on win32
> {{python3 -m pip install apache-flink==1.14.0}}
> pycharm
> Reporter: wangdonglin
> Assignee: Dian Fu
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.15.0, 1.14.3
>
> Attachments: demo999.log, demo999.py
>
>
> The following exception shown when executing PyFlink jobs according to the
> demo show in
> [https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/python/datastream/intro_to_datastream_api/]
>
> h2. Common Structure of Python DataStream API Programs
>
> Exception in thread Thread-15:
> Traceback (most recent call last):
> File "D:\soft\py\lib\threading.py", line 932, in _bootstrap_inner
> self.run()
> File
> "C:\Users\wangdonglin\AppData\Roaming\Python\Python38\site-packages\apache_beam\runners\worker\data_plane.py",
> line 218, in run
> while not self._finished.wait(next_call - time.time()):
> File "D:\soft\py\lib\threading.py", line 558, in wait
> signaled = self._cond.wait(timeout)
> File "D:\soft\py\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)
