sql-client pyexec参数生效疑问

Mon, 06 Jun 2022 20:24:10 -0700 

Hi，


环境：
- flink-1.14.3， 单机集群
- 服务器上默认python2，也存在python3.6.8
- /xxx/bin/python3是python3生成的虚拟环境


使用sql-client测试pyflink的udf，自定义了一个函数f1，/xxx/p.py
启动命令：
./bin/sql-client.sh -pyfs file:///xxx/p.py -pyexec /xxx/bin/python3 
配置pyexec指定了使用的python为python3


执行命令报错，报错信息如下：
Flink SQL> create temporary function fun1 as 'p.f1' language python;
[INFO] Execute statement succeed.
Flink SQL> select fun1('a',1,'s');
Traceback (most recent call last):
  File "/usr/lib64/python2.7/runpy.py", line 151, in _run_module_as_main
    mod_name, loader, code, fname = _get_module_details(mod_name)
  File "/usr/lib64/python2.7/runpy.py", line 101, in _get_module_details
    loader = get_loader(mod_name)
  File "/usr/lib64/python2.7/pkgutil.py", line 464, in get_loader
    return find_loader(fullname)
  File "/usr/lib64/python2.7/pkgutil.py", line 474, in find_loader
    for importer in iter_importers(fullname):
  File "/usr/lib64/python2.7/pkgutil.py", line 430, in iter_importers
    __import__(pkg)
  File "/home/flink-1.14.3/opt/python/pyflink.zip/pyflink/__init__.py", line 
26, in <module>
RuntimeError: Python versions prior to 3.6 are not supported for PyFlink 
[sys.version_info(major=2, minor=7, micro=5, releaselevel='final', serial=0)].
[ERROR] Could not execute SQL statement. Reason:
java.lang.IllegalStateException: Instantiating python function 'p.f1' failed.


报错提示中使用到的是python2，不是参数里面配置的python3，如何让pyexec生效？


Thx

回复