[ https://issues.apache.org/jira/browse/FLINK-24880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487602#comment-17487602 ]
Chris Roberts commented on FLINK-24880: --------------------------------------- I still see this error: ``` Traceback (most recent call last): File "c:\python\python38\lib\threading.py", line 558, in wait signaled = self._cond.wait(timeout) File "c:\python\python38\lib\threading.py", line 306, in wait gotit = waiter.acquire(True, timeout) OverflowError: timeout value is too large ``` python 3.8.10, pyflink 1.14.3 Are there some additional steps I need to take? > 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)