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

[chenwei (Jira)]

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)