向Apache Flink提交Python作业时出现Java错误的问题咨询
向Apache Flink提交Python作业时出现Java错误的问题咨询
大家好,我最近在提交Flink Python作业时碰到了个棘手的问题,想请教下社区的朋友们:
我本地用Python 3运行代码的时候一切正常,但当我执行命令 flink run -py {path_code} 把作业提交到Apache Flink时,却抛出了Java相关的错误(原场景附带了错误截图,显示提交流程中触发了Java层面的异常)。
我有点搞不懂,提交Python作业前是不是有什么我漏掉的前置配置或者准备步骤呀?毕竟我提交.jar格式的作业时完全没问题,运行得很顺畅。
最后补充下我的环境信息:已经安装好Apache Flink,Python版本是3.10。
备注:内容来源于stack exchange,提问作者Alvindra Renaldo




