flink version: Apache Flink 1.11.2 for Scala 2.12 

 

后运行,各种jar 包找不到

yarn-session.sh -n 1 -jm 1024m -tm 1024m

 

查看官网:https://flink.apache.org/downloads.html

可以知道我下载的flink 中没有hadoop 的包,官方附加了 hadoop 包的组件

flink yarn  error 缺少hadoop 包

选择对应的hadoop下载后,添加到 $FLINK_HOME/lib 下就可以了, 重新运行没有报错

 

相关文章:

  • 2021-12-11
  • 2022-12-23
  • 2021-09-23
  • 2021-08-09
  • 2021-07-05
  • 2021-05-19
猜你喜欢
  • 2022-12-23
  • 2022-12-23
  • 2021-07-20
  • 2022-12-23
  • 2021-12-29
  • 2021-12-24
相关资源
相似解决方案