[
https://issues.apache.org/jira/browse/FLINK-25207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17456853#comment-17456853
]
Dian Fu commented on FLINK-25207:
---------------------------------
[~Nakram] The above exception should doesn't affect the job execution. Besides,
it only appears in windows platform and has nothing to do with notebook.
Nevertheless it would be great to eliminate this error message as it's very
confusing for users.
> 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.1#820001)
