[FLINK-24267] PyFlink Table API example from docs does not work.

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.14.0
• Fix Version/s: 1.14.0
• Component/s: API / Python, Documentation
• Labels: pull-request-available
• Assignee: Dian Fu
• Reporter: Xintong Song
• Created: 13/Sep/21 06:37
• Updated: 14/Sep/21 06:37
• Resolved: 14/Sep/21 06:37

Description

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.

$ 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)

Issue Links

• Discovered while testing: FLINK-23821 Test loopback mode to allow Python UDF worker and client reuse the same Python VM
• links to: GitHub Pull Request #17273