Flink报错NoSuchMetchod的错误

2019-10-21  本文已影响0人  斗鱼_191f

问题原因一般有两种:

  1. 确实没有这个jar包导致
  2. Flink版本和connector版本不一致导致
    我的问题是Flink版本和Connector版本不一致导致的,其实Flink服务端用的版本是1.9.0,而kafka Connector版本没有和服务端版本保持一致。
    修改方式:Flink版本用1.9.0,则kafka-connector版本也用1.9.0.
    参考文章:https://juejin.im/post/5d844d11e51d4561e0516bbd
上一篇 下一篇

猜你喜欢

热点阅读