Re: python udf 提交到本地节点执行报错

2020-09-17 文章 myfjdthink
感谢搞定了,根据你提供的文档,我把命令改为 flink run -py src/etl/hello_world.py -pyexec /usr/local/opt/python@3.7/bin/python3 指定了 python 执行器就行了 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: python udf 提交到本地节点执行报错

2020-09-17 文章 myfjdthink
你好,我的本地集群是单点的,直接使用文档里的 bin/start-cluster.sh 命令启动的。 我扫了一遍文档,没找到介绍如何配置集群里的 pylink 相关的信息,可以麻烦你告诉我相关文档在哪里吗 -- Sent from: http://apache-flink.147419.n8.nabble.com/

python udf 提交到本地节点执行报错

2020-09-17 文章 myfjdthink
操作系统 Mac OS flink --version Version: 1.11.1, Commit ID: 7eb514a 代码 from pyflink.table import StreamTableEnvironment, EnvironmentSettings, DataTypes from pyflink.table.udf import udf # 1. create a TableEnvironment env_settings =