[
https://issues.apache.org/jira/browse/FLINK-33106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenwei updated FLINK-33106:
----------------------------
Attachment: (was: 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, 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)