[FLINK-20962] Rewrite the example in 'flink-python/pyflink/shell.py'

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: API / Python
• Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: Wei Zhong
• Created: 13/Jan/21 12:08
• Updated: 07/Nov/21 10:38

Description

Currently the pyflink example in 'flink-python/pyflink/shell.py' was added in version 1.9 and has not been updated since. We need to rewrite it with the latest recommended API.

Issue Links

• links to: GitHub Pull Request #14673