[FLINK-33106] pyflink脚本通过python命令运行正常，但部署至Flink（单机）运行时报错

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Invalid
• Affects Version/s: 1.17.0
• Component/s: API / Python, Connectors / FileSystem, FileSystems
• Labels: easyfix

Environment

Flink 1.17.0（单机），Python 3.9.10。

• Flags: Important

Language

Java Python

• Assignee: Unassigned
• Reporter: chenwei
• Created: 18/Sep/23 09:26
• Updated: 18/Sep/23 12:33
• Resolved: 18/Sep/23 12:33

Description

尊敬的开发老师，你们好。最近遇到一个问题，经搜索资料，仍无法解决，因此在这里反馈。

 

【问题描述】：

我用pyflink写了一个demo程序（参考附件《csv_batch_source_csv.py》），读取一个csv并打print。这个程序用python来运行是正常的，参考附件《python_cmd.txt》，但是通过flink run提交至flink环境执行时却报错，无法正确执行，参考附件《flink_cmd.txt》。

 

我怀疑是一个bug，但尚不确定，请老师评估，谢谢。