You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2022/04/27 08:29:00 UTC
[jira] [Closed] (FLINK-25207) sample pyflink from documentation doesn't work in jupyter notebooks
[ https://issues.apache.org/jira/browse/FLINK-25207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dian Fu closed FLINK-25207.
---------------------------
Resolution: Duplicate
Closing this issue as it has already been fixed in FLINK-25883.
> sample pyflink from documentation doesn't work in jupyter notebooks
> -------------------------------------------------------------------
>
> Key: FLINK-25207
> URL: https://issues.apache.org/jira/browse/FLINK-25207
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Affects Versions: 1.14.0
> Environment: Windows 3.10
> new conda environment, python = 3.8
> pip install apache-flink notebook kafka-python
> Reporter: Stephan Pirson
> Priority: Minor
>
> 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:
>
> {code:java}
> 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
> {code}
> In the command line where the notebook was started, the output of the job was printed:
>
> {code:java}
> WARNING: All illegal access operations will be denied in a future release
> +I[To, 1]
> +I[be,, 1]
> etc.{code}
>
> 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.
>
--
This message was sent by Atlassian Jira
(v8.20.7#820007)