wangdonglin created FLINK-24880:
-----------------------------------
Summary: pyflink 官网demo运行报错OverflowError: timeout value is too
large
Key: FLINK-24880
URL: https://issues.apache.org/jira/browse/FLINK-24880
Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.14.0
Environment: python 3.8.10
{{python3 -m pip install apache-flink==1.14.0}}
Reporter: wangdonglin
Attachments: demo999.log, demo999.py
运行pyflink官网demo，[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
[#|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
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
