Details
-
Bug
-
Status: Closed
-
Minor
-
Resolution: Duplicate
-
1.14.0
-
None
-
None
-
Windows 3.10
new conda environment, python = 3.8
pip install apache-flink notebook kafka-python
Description
copy/pasted the tutorial from this page:
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/python/datastream_tutorial/
into a new cell of a new notebook.
called word_count(None, None)
output cell was:
Executing word_count example with default input data set. Use --input to specify file input. Printing result to stdout. Use --output to specify output path. Exception in thread Thread-22: Traceback (most recent call last): File "E:\dev\Conda\envs\py38\lib\threading.py", line 932, in _bootstrap_inner self.run() File "E:\dev\Conda\envs\py38\lib\site-packages\apache_beam\runners\worker\data_plane.py", line 218, in run while not self._finished.wait(next_call - time.time()): File "E:\dev\Conda\envs\py38\lib\threading.py", line 558, in wait signaled = self._cond.wait(timeout) File "E:\dev\Conda\envs\py38\lib\threading.py", line 306, in wait gotit = waiter.acquire(True, timeout) OverflowError: timeout value is too large
In the command line where the notebook was started, the output of the job was printed:
WARNING: All illegal access operations will be denied in a future release
+I[To, 1]
+I[be,, 1]
etc.
If not easily fixable, maybe a mention that this doesn't work well in notebooks could be useful, considering how prevalent an environment they are.
Attachments
Issue Links
- duplicates
-
-
- Closed
-