[FLINK-15078] Report Python version exceptions in time

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Invalid
• Fix Version/s: 1.11.0
• Component/s: API / Python
• Assignee: Unassigned
• Reporter: sunjincheng
• Created: 05/Dec/19 12:26
• Updated: 21/Apr/20 06:43
• Resolved: 21/Apr/20 06:43

Description

Do not report Python version exceptions in time when Using the Python2.7 in flink 1.10.

We should do the follows config:

t_env.get_config().set_python_executable("python3")

although we can fix this issue by config, bug I think it's better to report Python version exceptions in time.

Shot error message:

RuntimeError: Python versions prior to 3.5 are not supported for PyFlink [sys.version_info(major=2, minor=7, micro=16, releaselevel='final', serial=0)].

The detail info can be found in Attachment.

Issue Links

• is blocked by: BEAM-8935 Fail fast if sdk harness startup failed