Xintong Song created FLINK-24267:
------------------------------------

             Summary: PyFlink Table API example from docs does not work.
                 Key: FLINK-24267
                 URL: https://issues.apache.org/jira/browse/FLINK-24267
             Project: Flink
          Issue Type: Bug
          Components: API / Python, Documentation
    Affects Versions: 1.14.0
            Reporter: Xintong Song
             Fix For: 1.14.0


I followed the following documentation to build and install pyflink from 
sources.
https://ci.apache.org/projects/flink/flink-docs-master/docs/flinkdev/building/#build-pyflink

Then I tried the WordCount.py example from the following documentation.
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/python/table_api_tutorial/

This results in the following error.
{code}
$ python WordCount.py
Traceback (most recent call last):
  File "WordCount.py", line 2, in <module>
    from pyflink.table.descriptors import Schema, FileSystem
ImportError: cannot import name 'FileSystem' from 'pyflink.table.descriptors' 
(/usr/local/opt/python@3.8/Frameworks/Python.framework/Versions/3.8/lib/python3.8/site-packages/pyflink/table/descriptors.py)
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to