💡
原文中文,约1400字,阅读约需4分钟。
📝
内容提要
同事遇到Flink客户端提交作业报错,检查配置项后发现是环境上的包版本不对,移动后问题解决。
🎯
关键要点
- 同事遇到Flink客户端提交作业报错,提示LocalStreamEnvironment无法使用。
- 初步判断可能是配置项错误,但确认没有最近的变更。
- 检查Flink配置文件flink-con.yml,未发现相关配置项。
- 通过堆栈信息和Flink源码进行代码定位,发现代码行数不一致。
- 确认使用的jar包与部门提供的版本不符,怀疑环境包有问题。
- 将不明版本的flink-streaming-java包移动后,作业成功提交。
➡️