[FLINK-24880] Error messages "OverflowError: timeout value is too large" shown when executing PyFlink jobs

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.14.0
• Fix Version/s: 1.14.4, 1.15.0
• Component/s: API / Python
• Labels: pull-request-available

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

• Assignee: Dian Fu
• Reporter: wangdonglin
• Created: 12/Nov/21 02:04
• Updated: 14/Feb/22 02:46
• Resolved: 14/Feb/22 02:46

Description

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/     

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

Issue Links

• links to: GitHub Pull Request #18292
• links to: GitHub Pull Request #18640