[FLINK-17114] When the pyflink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail.

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.1, 1.11.0
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Wei Zhong
• Reporter: Wei Zhong
• Created: 13/Apr/20 08:09
• Updated: 14/Apr/20 14:01
• Resolved: 14/Apr/20 14:00

Description

When the PyFlink job runs in local mode and the command "python" points to Python 2.7, the startup of the Python UDF worker will fail because "python" is the default interpreter of the Python UDF worker. For this case we need to set the default value of "python.executable" to `sys.executable` i.e. the python interpreter which launches the job.

Issue Links

• links to: GitHub Pull Request #11714
• links to: GitHub Pull Request #11729