[FLINK-25207] sample pyflink from documentation doesn't work in jupyter notebooks

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Duplicate
• Affects Version/s: 1.14.0
• Component/s: API / Python

Environment

Windows 3.10

new conda environment, python = 3.8

pip install apache-flink notebook kafka-python

• Assignee: Unassigned
• Reporter: Stephan Pirson
• Created: 07/Dec/21 09:16
• Updated: 27/Apr/22 08:28
• Resolved: 27/Apr/22 08:28

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.
 

Issue Links

• duplicates: FLINK-25883 The value of DEFAULT_BUNDLE_PROCESSOR_CACHE_SHUTDOWN_THRESHOLD_S is too large