chenwei created FLINK-33106:
-------------------------------
Summary: pyflink脚本通过python命令运行正常,但部署至Flink(单机)运行时报错
Key: FLINK-33106
URL: https://issues.apache.org/jira/browse/FLINK-33106
Project: Flink
Issue Type: Bug
Components: API / Python, Connectors / FileSystem, FileSystems
Affects Versions: 1.17.0
Environment: Flink 1.17.0(单机),Python 3.9.10。
Reporter: chenwei
Attachments: csv_batch_source_csv.py, flink_cmd.txt, python_cmd.txt
尊敬的开发老师,你们好。最近遇到一个问题,经搜索资料,仍无法解决,因此在这里反馈。
【问题描述】:
我用pyflink写了一个demo程序(参考附件《csv_batch_source_csv.py》),读取一个csv并打print。这个程序用python来运行是正常的,参考附件《python_cmd.txt》,但是通过flink
run提交至flink环境执行时却报错,无法正确执行,参考附件《flink_cmd.txt》。
我怀疑是一个bug,但尚不确定,请老师评估,谢谢。
--
This message was sent by Atlassian Jira
(v8.20.10#820010)