[
https://issues.apache.org/jira/browse/FLINK-24880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangdonglin updated FLINK-24880:
--------------------------------
Description:
运行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
was:
运行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
> 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
> Priority: Major
> 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)
