感谢搞定了,根据你提供的文档,我把命令改为
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/
你好,我的本地集群是单点的,直接使用文档里的
bin/start-cluster.sh
命令启动的。
我扫了一遍文档,没找到介绍如何配置集群里的 pylink 相关的信息,可以麻烦你告诉我相关文档在哪里吗
--
Sent from: http://apache-flink.147419.n8.nabble.com/
操作系统
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 =