记录一次由于Jar包冲突导致的神奇问题

记录一次由于Jar包冲突导致的神奇问题

💡 原文中文,约1400字,阅读约需4分钟。
📝

内容提要

同事遇到Flink客户端提交作业报错,检查配置项后发现是环境上的包版本不对,移动后问题解决。

🎯

关键要点

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

继续阅读