sunjincheng created FLINK-15078:
-----------------------------------
Summary: Report Python version exceptions in time
Key: FLINK-15078
URL:
https://issues.apache.org/jira/browse/FLINK-15078 Project: Flink
Issue Type: Improvement
Components: API / Python
Reporter: sunjincheng
Fix For: 1.11.0
Attachments: flink-jincheng.sunjc-python-udf-boot-jincheng.local.log
Do not report Python version exceptions in time when Using the Python2.7 in flink 1.10.
We should do the follows config:
{code}
t_env.get_config().set_python_executable("python3")
{code}
although we can fix this issue by config, bug I think it's better to report Python version exceptions in time.
Shot error message:
{code}
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)].
{code}
The detail info can be found in Attachment.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)