使用pyflink时报错了
Python 3.7.3 (default, Mar 27 2019, 22:11:17) [GCC 7.3.0] :: Anaconda, Inc. on linux Type "help", "copyright", "credits" or "license" for more information.
from pyflink.table import BatchTableEnvironment, EnvironmentSettings from pyflink.table.descriptors import FileSystem, OldCsv, Schema from pyflink.table.types import DataTypes from pyflink.table.udf import udf environment_settings = EnvironmentSettings.new_instance().in_batch_mode().use_blink_planner().build() Traceback (most recent call last): File " ", line 1, in File "/py3/lib/python3.7/site-packages/pyflink/table/environment_settings.py", line 187, in new_instance return EnvironmentSettings.Builder() File "/py3/lib/python3.7/site-packages/pyflink/table/environment_settings.py", line 46, in init gateway = get_gateway() File "/py3/lib/python3.7/site-packages/pyflink/java_gateway.py", line 68, in get_gateway callback_server_listening_address, callback_server_listening_port) TypeError: 'JavaPackage' object is not callable
写回答
-
执行bin/flink run -py flink_sql_test.py报错 $ bin/flink run -py flink_sql_test.py Traceback (most recent call last): File "flink_sql_test.py", line 2, in from pyflink.datastream import StreamExecutionEnvironment File "/data/software/flink-1.11.0/opt/python/pyflink.zip/pyflink/ init.py", line 24, in RuntimeError: Python versions prior to 3.5 are not supported for PyFlink [sys.version_info(major=2, minor=7, micro=5, releaselevel='final', serial=0)]. org.apache.flink.client.program.ProgramAbortException at org.apache.flink.client.python.PythonDriver.main(PythonDriver.java:95) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:288) at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198) at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:149) at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:699) at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:232) at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:916) at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:992) at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:992)
解决办法： 当我们不想使用系统默认的python环境执行pyFlink时，比如我们想用Anaconda的环境，但是我们又不想修改系统默认环境，你可以这样解决： 在con/flink-conf.yaml下添加你自己的执行Python环境
2021-02-19 14:22:56赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
