[ 
https://issues.apache.org/jira/browse/FLINK-33106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

chenwei updated FLINK-33106:
----------------------------
    Attachment: flink_cmd.txt

> 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
>            Priority: Critical
>              Labels: easyfix
>         Attachments: csv_batch_source_csv.py, flink_cmd.txt, python_cmd.txt
>
>   Original Estimate: 1m
>  Remaining Estimate: 1m
>
> 尊敬的开发老师,你们好。最近遇到一个问题,经搜索资料,仍无法解决,因此在这里反馈。
>  
> 【问题描述】:
> 我用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)

Reply via email to