作者:jason---zhu | 来源:互联网 | 2023-08-07 09:22
flinkversion: ApacheFlink1.11.2forScala2.12 后运行,各种jar包找不到yarn-session.sh-n1-jm1024m-tm102
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 包的组件
选择对应的hadoop下载后,添加到 $FLINK_HOME/lib 下就可以了, 重新运行没有报错